INTERNAL: Make the -S option available with ascii protocol

[namsic]

🔗 Related Issue

• jam2in/arcus-works#634

⌨️ What I did

-S option을 ascii protocol과 함께 사용할 수 있도록 확장합니다.
ascii protocol에서 SASL 인증 수행할 방법이 없는 상태이므로,
-S 옵션 사용 시 ascii conn에서는 허용된 명령만 사용할 수 있습니다.

1. 기존에는 -S option을 설정하면 binary protocol으로 고정되고,
   -B option에서 auto나 ascii를 명시한 상태에서 -S 함께 지정하면 구동 실패합니다.

2. 변경 후에는 -S option을 설정하더라도 ascii protocol을 사용할 수 있습니다.

3. -S option을 설정하여 구동한 경우에 ascii protocol 사용하는 연결은
   허용되지 않은 명령에 대해 CLIENT_ERROR unauthenticated 응답합니다.

[jhpark816]

flush 명령은 ?

[namsic]

일반적으로 접근 제한이라는 표현은 read/write를 아우르는 의미로 사용하는 경우가 많고
flush는 캐시 아이템에 대한 write 성격의 명령이라고 생각해서 허용 명령에서 제외했습니다.

그런데 생각해 보니 응용에서 특정 key나 prefix를 제거해 달라는 요청이 있을 수 있고
flush, delete 명령을 허용한다고 해서 저장된 정보를 알 수 있게 되는 것이 아니므로
이러한 명령을 허용하는 것이 유용한가 하는 생각도 들기는 합니다.

제 생각에 flush를 운영 계열의 명령으로 분류했을 때 문제가 되는 부분은,
인증하지 않은 사용자 or 모니터링 프로세스가 캐시 데이터를 전부 제거할 수 있다고 해석할 여지가 있다는 점 입니다.

[jhpark816]

리뷰 완료

[jhpark816]

아래 형태로 변경하시죠. 아래 코드가 직관적으로 읽기가 쉽습니다.

static bool authenticated_ascii(conn *c, token_t *tokens, const size_t ntokens)
{
    if (c->authenticated) {
        return true;
    }
    if ((ntokens >= 2) &&
        (strcmp(tokens[COMMAND_TOKEN].value, "dump") == 0 ||
         strcmp(tokens[COMMAND_TOKEN].value, "cmdlog") == 0 ||
         . . . 
         strcmp(tokens[COMMAND_TOKEN].value, "version") == 0 ||
         strcmp(tokens[COMMAND_TOKEN].value, "zkensemble") == 0)) {
        return true;
    }
    if ((ntokens >= 3) &&
        (strcmp(tokens[COMMAND_TOKEN].value, "set") == 0 ||
         strcmp(tokens[COMMAND_TOKEN].value, "get") == 0)) {
        return (strncmp(tokens[KEY_TOKEN].value, "arcus:", 6) == 0);
    }
    if ((ntokens >= 5) &&
        (strcmp(tokens[COMMAND_TOKEN].value, "lop") == 0 ||
         ...
         strcmp(tokens[COMMAND_TOKEN].value, "bop") == 0)) {
        return (strncmp(tokens[COMMAND_TOKEN+2].value, "arcus:", 6) == 0);
    }
    return false;
}

[namsic]

• 허용 명령에 flush_XXX 명령 추가
• 조건문 코드 변경

[jhpark816]

@namsic
아래와 같이 조금이라도 최적화하는 방안을 검토해 주세요.

    if ((ntokens >= 5) &&
        (strcmp(tokens[COMMAND_TOKEN].value+1, "op ") == 0)) { // lop, sop, mop, bop
        return (strncmp(tokens[COMMAND_TOKEN+2].value, "arcus:", 6) == 0);
    }
    if ((ntokens >= 3) &&
        (strcmp(tokens[COMMAND_TOKEN].value+1, "et ") == 0)) { // get, set
        return (strncmp(tokens[KEY_TOKEN].value, "arcus:", 6) == 0);
    }
    if ((ntokens >= 2) &&
        (strcmp(tokens[COMMAND_TOKEN].value, "dump") == 0 ||
         strcmp(tokens[COMMAND_TOKEN].value, "cmdlog") == 0 ||
         strcmp(tokens[COMMAND_TOKEN].value, "config") == 0 ||
         strcmp(tokens[COMMAND_TOKEN].value, "flush_all") == 0 ||
         strcmp(tokens[COMMAND_TOKEN].value, "flush_prefix") == 0 ||
         strcmp(tokens[COMMAND_TOKEN].value, "getattr") == 0 ||
         strcmp(tokens[COMMAND_TOKEN].value, "help") == 0 ||
         strcmp(tokens[COMMAND_TOKEN].value, "lqdetect") == 0 ||
         strcmp(tokens[COMMAND_TOKEN].value, "scan") == 0 ||
         strcmp(tokens[COMMAND_TOKEN].value, "setattr") == 0 ||
         strcmp(tokens[COMMAND_TOKEN].value, "stats") == 0 ||
         strcmp(tokens[COMMAND_TOKEN].value, "zkensemble") == 0)) {
        return true;
    }
    if ((ntokens == 2) &&
        (strcmp(tokens[COMMAND_TOKEN].value, "quit") == 0 ||
         strcmp(tokens[COMMAND_TOKEN].value, "ready") == 0 ||
         strcmp(tokens[COMMAND_TOKEN].value, "version") == 0 ||
         strcmp(tokens[COMMAND_TOKEN].value, "shutdown") == 0)) {
        return true;
    } 

[namsic]

첫 글자 확인하여 switch한 뒤 문자열 비교하는 구현도 검토할 만한 것 같습니다.

https://github.com/naver/arcus-c-client/blob/09c014d1fd0a97f3ab19ea46422251a4db3dbf25/libmemcached/response.cc#L281

  switch(buffer[0])
  {
  case 'V':
    if (memcmp(buffer, "VALUE", 5) == 0)
    {
      /* We add back in one because we will need to search for END */
      memcached_server_response_increment(ptr);
      return textual_value_fetch(ptr, buffer, buffer_length, result);
    }
    else if (memcmp(buffer, "VERSION", 7) == 0)
    {
      /* Find the space, and then move one past it to copy version */
      char *version_ptr= index(buffer, ' ');
      version_ptr++;
      return textual_version_fetch(ptr, version_ptr);
    }
    break;

[jhpark816]

@namsic
c client 방식으로 구현합시다.