const http = require('http');

const query =
{
    create:
    {
    },

    query:
    {
        col: "users",

        projection:
        {
            name: true,
            nickname: true,
            displayName: true,
            _id: true,
            email: true,
        }
    },

    modify:
    {
    },

    delete:
    {
    }
}

const cmp_query =
{
    col:
    {
        name: "post",

        create:
        {
        },

        query:
        {
        },

        modify:
        {
        },

        delete:
        {
        },
    }
}

const postSubscription =
{
    subscribe:
    {
        collection: true,

        posts: true,

        projection:
        {
            _id: true,
            body: true
        }
    }
}

const requestOptions =
{
    host: 'localhost',
    port: '4201',
    path: '/fetch',
    method: 'POST',
    headers:
    {
        'Content-Type': 'application/json',
    }
};

var reqData = "";

var postReq = http.request(requestOptions,
    (request) =>
    {
        request.setEncoding("utf-8");

        request.on('data',
            (data) =>
            {
                reqData += data;
            });

            request.on('end',
            () =>
            {
                console.log(JSON.parse(reqData));
            });
    });

postReq.on('error',
    (e) =>
    {
        console.log(`error: ${e.message}`);
    });

postReq.write(JSON.stringify(postSubscription));
postReq.end();