package com.google.tagpost;

import com.google.tagpost.spanner.DataService;
import io.grpc.Status;
import io.grpc.stub.StreamObserver;
import io.grpc.StatusRuntimeException;

import java.util.List;
import com.google.inject.Inject;
import com.google.common.flogger.FluentLogger;

/** Encapsulate all RPC methods of {@link TagpostServer} */
public final class TagpostService extends TagpostServiceGrpc.TagpostServiceImplBase {

  private static final FluentLogger logger = FluentLogger.forEnclosingClass();
  private final DataService dataService;

  @Inject
  public TagpostService(DataService dataService) {
    this.dataService = dataService;
  }

  @Override
  public void fetchMessage(
      FetchMessageRequest req, StreamObserver<FetchMessageResponse> responseObserver) {
    FetchMessageResponse response = fetchMessageImpl(req);
    responseObserver.onNext(response);
    responseObserver.onCompleted();
  }

  @Override
  public void fetchThreadsByTag(
      FetchThreadsByTagRequest req, StreamObserver<FetchThreadsByTagResponse> responseObserver) {
    try {
      FetchThreadsByTagResponse response = fetchThreadsByTagImpl(req);
      responseObserver.onNext(response);
      responseObserver.onCompleted();
    } catch (Exception e) {
      Status status = Status.INTERNAL.withDescription(e.getMessage());
      logger.atWarning().withCause(e).log("Fetch Threads By Tag Failed");
      responseObserver.onError(status.asRuntimeException());
    }
  }

  @Override
  public void fetchCommentsUnderThread(
      FetchCommentsUnderThreadRequest req,
      StreamObserver<FetchCommentsUnderThreadResponse> responseObserver) {
    try {
      FetchCommentsUnderThreadResponse response = fetchCommentsUnderThreadImpl(req);
      responseObserver.onNext(response);
      responseObserver.onCompleted();
    } catch (Exception e) {
      Status status = Status.INTERNAL.withDescription(e.getMessage());
      logger.atWarning().withCause(e).log("Fetch Comments UnderThread Failed");
      responseObserver.onError(status.asRuntimeException());
    }
  }

  private FetchThreadsByTagResponse fetchThreadsByTagImpl(FetchThreadsByTagRequest req) {
    String tag = req.getTag();
    logger.atInfo().log("Fetching all Threads with primaryTag = " + tag);
    List<Thread> threadList = dataService.getAllThreadsByTag(tag);
    FetchThreadsByTagResponse response =
        FetchThreadsByTagResponse.newBuilder().addAllThreads(threadList).build();
    return response;
  }

  private FetchCommentsUnderThreadResponse fetchCommentsUnderThreadImpl(
      FetchCommentsUnderThreadRequest req) {
    long threadId = req.getThreadId();
    logger.atInfo().log("Fetching all comments under threadID = " + threadId);
    List<Comment> commentList = dataService.getAllCommentsByThreadId(threadId);
    FetchCommentsUnderThreadResponse response =
        FetchCommentsUnderThreadResponse.newBuilder().addAllComment(commentList).build();
    return response;
  }

  private FetchMessageResponse fetchMessageImpl(FetchMessageRequest req) {
    FetchMessageResponse response =
        FetchMessageResponse.newBuilder().setMessage("Request received.").build();
    return response;
  }
}

@@ -3026,47 +3026,14 @@
     
-FetchMessageResponse response =%0A       
+return
  Fet
@@ -3104,35 +3104,14 @@
 uild();%0A
-    return response;%0A
   %7D%0A%7D%0A

refactor fetchMessageImpl