/*
 * svc_init_pipe.c
 *
 * Copyright (c) 2018-2021 Eric Vidal <eric@obarun.org>
 *
 * All rights reserved.
 *
 * This file is part of Obarun. It is subject to the license terms in
 * the LICENSE file found in the top-level directory of this
 * distribution.
 * This file may not be copied, modified, propagated, or distributed
 * except according to the terms contained in the LICENSE file./
 */

#include <66/svc.h>

#include <string.h>

#include <oblibs/log.h>

#include <skalibs/genalloc.h>
#include <skalibs/stralloc.h>
#include <skalibs/tai.h>

#include <s6/ftrigr.h>
#include <s6/ftrigw.h>
#include <s6/supervise.h>

#include <66/utils.h>
#include <66/resolve.h>


int svc_init_pipe(ftrigr_t *fifo,genalloc *gasv,tain *deadline)
{
    log_flow() ;

    size_t i = 0 ;
    ss_resolve_sig_t *svc ;

    if (!ftrigr_startf_g(fifo, deadline))
        log_warnusys_return(LOG_EXIT_ZERO,"initiate fifo") ;

    for (; i < genalloc_len(ss_resolve_sig_t,gasv) ; i++)
    {
        svc = &genalloc_s(ss_resolve_sig_t,gasv)[i] ;
        char *svok = svc->res.sa.s + svc->res.runat ;
        size_t scanlen = strlen(svok) ;
        char svfifo[scanlen + 6 + 1] ;
        memcpy(svfifo, svok,scanlen) ;
        memcpy(svfifo + scanlen, "/event",6) ;
        svfifo[scanlen + 6] = 0 ;

        log_trace("clean up fifo: ", svfifo) ;
        if (!ftrigw_clean (svok))
            log_warnusys_return(LOG_EXIT_ZERO,"clean up fifo: ", svfifo) ;

        log_trace("subcribe to fifo: ",svfifo) ;
        svc->ids = ftrigr_subscribe_g(fifo, svfifo, "[DuUdOxs]", FTRIGR_REPEAT, deadline) ;
        if (!svc->ids)
            log_warnusys_return(LOG_EXIT_ZERO,"subcribe to fifo: ",svfifo) ;
    }
    return 1 ;
}