INTERNAL: add PipeOperationImpl to reduce duplicate code

[oliviarla]

🔗 Related Issue

• 앞으로 pipe operation implementation 변경 지점이 많아질 것을 고려하여 PipeOperationImpl 클래스를 추가하여 이를 각각의 클래스가 상속받도록 합니다.
• 또한, 이전에 pipe_error까지 읽는 로직을 CollectionPipedInsertOperationImpl에만 적용했었기 때문에, 하나의 추상 클래스를 상속받도록 하여 CollectionPipedUpdateOperationImpl, CollectionPipedExistOperationImpl, CollectionBulkInsertOperationImpl에도 적용하고자 합니다.

⌨️ What I did

• handleLine, initialize 등의 메서드 중복과 static 필드 중복을 제거하였습니다.
• handleLine에서 각 연산(insert/exist/update/bulk insert)마다 다르게 처리해야 하는 부분은 추상 메서드로 빼 각 클래스에서 구현하도록 하였습니다.
• wasCancelled 메서드는 연산마다 다룰 CANCELLED 상태가 달라 각 클래스에서 구현하도록 하였습니다.
• getInsert/ getExist / getUpdate 메서드는 형변환이 필요하기 때문에 각 클래스에서 구현하도록 하였습니다.

[jhpark816]

리뷰 완료

[oliviarla]

@uhm0311 @jhpark816 다시 리뷰 부탁드립니다.

[jhpark816]

일부 리뷰

[jhpark816]

STORE_CANCELED와 EXIST_CANCELED는 사실상 같은 객체입니다.
CANCELED 객체 하나로 통일하면 될 것 같습니다.

[jhpark816]

아래 형태의 wasCancelled() 메소드를 여기 클래스에 두면 될 것 같습니다.

  protected void wasCancelled() {
    OperationStatus status = new CollectionOperationStatus(
          false, "collection canceled", CollectionResponse.CANCELED);
    getCallback().receivedStatus(status);
  }

[jhpark816]

Bulk 연산인 경우에도 isNotPiped()이면 singleKey일 것입니다.
이 경우, addRedirectSingleKeyOperation() 호출합니다.

Bulk 연산의 기존 코드는 isNotPiped() 여부에 관계 없이
addRedirectMultiKeyOperation() 호출하였습니다.

문제가 있는 지 확인 바랍니다.

[uhm0311]

멀티키 연산의 경우 Redirect가 필요한 키만을 새로운 연산 객체에 복제하는 로직이 있습니다.
따라서 현재 상태로는 아마 이미 처리가 완료된 키도 그대로 Redirect 되어 중복 적용될 것으로 보입니다.

[jhpark816]

추가 리뷰

[jhpark816]

keys 인자만으로는 아래 경우를 구분하기가 어렵습니다.

• single key pipe
• multiple key pipe, but key count == 1

이를 구분하려면, boolean isBulk 인자를 추가하거나
collectionPipe 인자를 통해 isBulk 인지를 확인해야 합니다.

[jhpark816]

isSingleKey 사용되는 곳을 보니,
multiple key pipe인 bulk 연산이 아님을 확인하고 그에 따라 처리하기 위함으로 보입니다.
따라서, 단순히 keys.size()로 비교하는 것은 맞지 않고,
collectionPipe가 CollectionBulkInsert 타입이 아닌 지를 확인해야 할 것 같습니다.

[jhpark816]

질문입니다.
isNotPiped() 경우에서 NOT_MY_KEY 응답을 받으면,
single key pipe이든 multi key pipe이든 관계없이 아래 로직을 사용할 수 있나요?

       addRedirectSingleKeyOperation(line, keys.get(index));
       transitionState(OperationState.REDIRECT);