"use strict";
 
const { ServiceBroker } = require("moleculer");
const DbService = require("moleculer-db");
const MacroMetaAdapter = require("moleculer-db-adapter-macrometa");
const Sequelize = require("sequelize");
 
const broker = new ServiceBroker();
 
// Create a Sequelize service for `post` entities
broker.createService({
    name: "posts",
    mixins: [DbService],
    adapter: new MacroMetaAdapter({
        config: "https://gdn1.macrometa.io",
 
        auth: {
            email: "macrometa@moleculer.services",
            password: "secretpass"
        },
 
        tenant: null, // use default
        fabric: null // use default
    }),
    collection: "posts" // Name of collection
});
 
 
broker.start()
// Create a new post 
.then(() => broker.call("posts.create", {
    title: "My first post",
    content: "Lorem ipsum...",
    votes: 0
}))
 
// Get all posts
.then(() => broker.call("posts.find").then(console.log));

// posts.service.js
module.exports = {
    name: "posts",
    adapter: new MacroMetaAdapter(),
    actions: {
        findHello2() {
            return this.adapter.db.query("SELECT * FROM posts WHERE title = 'Hello 2' LIMIT 1")
                .then(([res, metadata]) => res);
        }
    }
}

// posts.service.js
module.exports = {
    name: "posts",
    adapter: new MacroMetaAdapter(),
    methods: {
        onChanges(payload) {
            this.logger.info("Collection has been changed", payload);
        }
    },
    async started() {
        await this.adapter.subscribeToChanges((err msg) => {
            if (err)
                return this.logger.error("Subscription error", err);
 
            this.onChanges(msg.payload);
        });
    },
 
    async stopped() {
        await this.adapter.unsubscribeFromChanges();
    }
}

await this.adapter.saveQuery(name, query, parameters);
await this.adapter.executeSavedQuery(name,variables);