changelog-server/dbInit/index.js

// dbInit/index.js 

"use strict"

const dbInit = {};

const bulkData = [
  { "index" : { "_index" : "changelog" } },
  { "author" : "John Ripper <john@theripper.com", 
    "content":"* machines: Installed the server\n```debootstrap -t foobar```", 
    "server": "server.example.com",
    "created_at":"2020-05-23T09:50:33.397Z"},
  { "index" : { "_index" : "changelog" } },
  { "author" : "John Ripper <john@theripper.com", 
    "content":"* db: Installed mysql\n```apt install mariadb-server```", 
    "server": "server.example.com",
    "created_at":"2020-05-23T10:50:33.397Z"},
  { "index" : { "_index" : "changelog" } },
  { "author" : "John Ripper <john@theripper.com", 
    "content":"* nginx: add package\n```apt install nginx-full```", 
    "server": "server.example.com",
    "created_at":"2020-05-23T16:50:33.397Z"}
];

const mappings = {
    "properties": {
      "author":    { "type": "keyword" },  
      "server":    { "type": "keyword" },  
      "content":  { "type": "text"  }, 
      "created_at":   { "type": "date","format": "date_optional_time" }     
    }};
    
const elasticsearch = require('elasticsearch');
var client = new elasticsearch.Client({
  host: process.env.ES_CONNECT,
//  log: 'trace',
  apiVersion: '7.7'
});

dbInit.client = client;
dbInit.bulkData = bulkData;
dbInit.mappings = mappings;

/**
 * 
 * @param {object} flags
 * @returns {int}
 */
dbInit.init = function( flags = {} ){
  
  var seed = flags.seed || true;
  
  this.client.indices.create({
    index : "changelog",
    body: {
      mappings: this.mappings
    }
  }).then( (result) => {
    
    console.log( "Index 'changelog' created with success.");
    
    // seed if flag ok
    if( ! seed ){ return true; };
    this.client.bulk({
      index: "changelog",
      body:  this.bulkData


      }).then( (r) => {
        console.log( "bulk insert OK");
      }, (r) => {
        console.log( "bulk insert ERROR! : ",r);
      });
  },( result ) => {
    console.log( "Index 'changelog' already exists, skipping.");
  });

  this.client.indices.create({
    index : "changelog-trash",
    body: {
      mappings: this.mappings
    }
  }).then( (result) => {
    
    console.log( "Index 'changelog-trash' created with success.");
  },( result ) => {
    console.log( "Index changelog-trash exists, skipping.");
  });
    
  
};

module.exports = dbInit;

// EOF