'use strict';
 
const { ServiceBroker } = require('moleculer');
const DbService = require('moleculer-db');
const DynamoAdapter = require('moleculer-db-adapter-dynamodb');
const dynamodb = require('dynamodb');
const Joi = require('joi');
 
const broker = new ServiceBroker();
 
// Create a dynamodb service for `post` entities
broker.createService({
  name: 'posts',
  mixins: [DbService],
  adapter: new DynamoAdapter({
    accessKeyId: '', // your id here
    secretAccessKey: '', // your key here
    region: '', // your region here
  }),
  model: dynamodb.define('Post', {
    id: dynamo.types.uuid(),
    title: Joi.string().required(),
    content: Joi.string().required(),
    votes: Joi.number(),
  }),
});
 
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));

new DynamoAdapter({
  accessKeyId: '', // your id here
  secretAccessKey: '', // your key here
  region: '', // your region here
});