/* Processed by ecpg (15.18 (Debian 15.18-0+deb12u1)) */
/* These include files are added by the preprocessor */
#include <ecpglib.h>
#include <ecpgerrno.h>
#include <sqlca.h>
/* End of automatic include section */

#line 1 "app/online/mg_ol_0010.pgc"
/* @tier medium @module mg @transform msg-gateway-online */
/*
 * mg_ol_0010.pgc - 전문 압축/해제 서비스 (MG_OL_0010)  [tier=medium]
 *
 * RAWMSG 를 RLE(Run-Length Encoding) 유사 방식으로 압축하여 압축길이/
 * 압축비를 산출한다. 압축결과를 다시 해제하여 원본과 일치하는지 검증
 * (round-trip)하고 압축통계와 검증결과를 응답한다. 순수 로직.
 */
#include <stdio.h>
#include <string.h>

#include "txcore.h"
#include "txcore_dbio.h"
#include "acq_util.h"
#include "mg_core.h"


#line 1 "/usr/include/postgresql/sqlca.h"
#ifndef POSTGRES_SQLCA_H
#define POSTGRES_SQLCA_H

#ifndef PGDLLIMPORT
#if  defined(WIN32) || defined(__CYGWIN__)
#define PGDLLIMPORT __declspec (dllimport)
#else
#define PGDLLIMPORT
#endif							/* __CYGWIN__ */
#endif							/* PGDLLIMPORT */

#define SQLERRMC_LEN	150

#ifdef __cplusplus
extern "C"
{
#endif

struct sqlca_t
{
	char		sqlcaid[8];
	long		sqlabc;
	long		sqlcode;
	struct
	{
		int			sqlerrml;
		char		sqlerrmc[SQLERRMC_LEN];
	}			sqlerrm;
	char		sqlerrp[8];
	long		sqlerrd[6];
	/* Element 0: empty						*/
	/* 1: OID of processed tuple if applicable			*/
	/* 2: number of rows processed				*/
	/* after an INSERT, UPDATE or				*/
	/* DELETE statement					*/
	/* 3: empty						*/
	/* 4: empty						*/
	/* 5: empty						*/
	char		sqlwarn[8];
	/* Element 0: set to 'W' if at least one other is 'W'	*/
	/* 1: if 'W' at least one character string		*/
	/* value was truncated when it was			*/
	/* stored into a host variable.             */

	/*
	 * 2: if 'W' a (hopefully) non-fatal notice occurred
	 */	/* 3: empty */
	/* 4: empty						*/
	/* 5: empty						*/
	/* 6: empty						*/
	/* 7: empty						*/

	char		sqlstate[5];
};

struct sqlca_t *ECPGget_sqlca(void);

#ifndef POSTGRES_ECPG_INTERNAL
#define sqlca (*ECPGget_sqlca())
#endif

#ifdef __cplusplus
}
#endif

#endif

#line 17 "app/online/mg_ol_0010.pgc"


#define MG10_MAXRUN 255

TX_SERVICE(MG_OL_0010, ctx)
{
    char raw[256];
    unsigned char comp[512];
    char verify[256];
    int  rawlen, complen, vlen;
    int  i, j;
    long ratio;

    tx_log(TX_LOG_INFO, "[MG_OL_0010] 전문 압축/해제 서비스 진입");

    /* 1) 원문 수신 */
    if (tx_buf_get(ctx->in, "RAWMSG", raw, sizeof(raw)) != TX_OK) {
        tx_log(TX_LOG_ERROR, "[MG_OL_0010] 원문(RAWMSG) 누락");
        tx_return(ctx, TX_EINVAL, ctx->out);
        return;
    }
    rawlen = (int)strlen(raw);
    if (rawlen <= 0) {
        tx_log(TX_LOG_WARN, "[MG_OL_0010] 압축 대상 길이 0");
        tx_return(ctx, TX_EINVAL, ctx->out);
        return;
    }

    /* 2) RLE 압축: (반복횟수, 문자) 쌍 스트림 생성 */
    complen = 0;
    i = 0;
    while (i < rawlen) {
        int run = 1;
        while (i + run < rawlen && raw[i + run] == raw[i] && run < MG10_MAXRUN)
            run++;
        if (complen + 2 > (int)sizeof(comp)) {
            tx_log(TX_LOG_ERROR, "[MG_OL_0010] 압축버퍼 초과 complen=%d", complen);
            tx_return(ctx, TX_ENOMEM, ctx->out);
            return;
        }
        comp[complen++] = (unsigned char)run;
        comp[complen++] = (unsigned char)raw[i];
        i += run;
    }

    /* 3) 해제(round-trip) 검증 */
    vlen = 0;
    for (j = 0; j + 1 < complen; j += 2) {
        int cnt = comp[j];
        int k;
        for (k = 0; k < cnt && vlen < (int)sizeof(verify) - 1; k++)
            verify[vlen++] = (char)comp[j + 1];
    }
    verify[vlen] = '\0';

    if (vlen != rawlen || memcmp(verify, raw, rawlen) != 0) {
        tx_log(TX_LOG_ERROR, "[MG_OL_0010] round-trip 불일치 raw=%d vlen=%d", rawlen, vlen);
        tx_buf_reset(ctx->out);
        tx_buf_sets(ctx->out, "RESP", RESP_SYSERR);
        tx_buf_setlong(ctx->out, "VERIFY", 0);
        tx_return(ctx, TX_FAIL, ctx->out);
        return;
    }

    /* 4) 압축비(%) = 압축길이 * 100 / 원문길이 (낮을수록 효율적) */
    ratio = (long)complen * 100 / (long)rawlen;

    /* 5) 압축 통계 응답 */
    tx_buf_reset(ctx->out);
    tx_buf_sets(ctx->out, "RESP", RESP_OK);
    tx_buf_setlong(ctx->out, "RAWLEN", (long)rawlen);
    tx_buf_setlong(ctx->out, "COMPLEN", (long)complen);
    tx_buf_setlong(ctx->out, "RATIO", ratio);
    tx_buf_setlong(ctx->out, "VERIFY", 1);

    /* 6) 압축 통계(mg_compress_stat)를 임베디드 SQL 로 적재 */
    {
        /* exec sql begin declare section */
         
         
         
        
#line 95 "app/online/mg_ol_0010.pgc"
 long h_raw_len ;
 
#line 96 "app/online/mg_ol_0010.pgc"
 long h_comp_len ;
 
#line 97 "app/online/mg_ol_0010.pgc"
 long h_ratio ;
/* exec sql end declare section */
#line 98 "app/online/mg_ol_0010.pgc"


        h_raw_len  = (long)rawlen;
        h_comp_len = (long)complen;
        h_ratio    = ratio;

        if (tx_begin() == TX_OK) {
            { ECPGdo(__LINE__, 0, 1, NULL, 0, ECPGst_normal, "insert into mg_compress_stat ( raw_len , comp_len , comp_ratio ) values ( $1  , $2  , $3  )", 
	ECPGt_long,&(h_raw_len),(long)1,(long)1,sizeof(long), 
	ECPGt_NO_INDICATOR, NULL , 0L, 0L, 0L, 
	ECPGt_long,&(h_comp_len),(long)1,(long)1,sizeof(long), 
	ECPGt_NO_INDICATOR, NULL , 0L, 0L, 0L, 
	ECPGt_long,&(h_ratio),(long)1,(long)1,sizeof(long), 
	ECPGt_NO_INDICATOR, NULL , 0L, 0L, 0L, ECPGt_EOIT, ECPGt_EORT);}
#line 107 "app/online/mg_ol_0010.pgc"

            if (sqlca.sqlcode != TX_SQL_OK) {
                TX_DBIO_LOG_ERR("INSERT mg_compress_stat");
                tx_abort();
            } else {
                tx_commit();
            }
        }
    }

    tx_log(TX_LOG_INFO, "[MG_OL_0010] 압축완료 raw=%d comp=%d ratio=%ld%%",
           rawlen, complen, ratio);
    tx_return(ctx, TX_OK, ctx->out);
}