The cost of not knowing MongoDB (V5RX) - Part 2

1
const buildId = (key: string, date: Date): Buffer => {
2
  const [YYYY, MM] = date.toISOString().split();
3
  
4
  return Buffer.from(`${key}${YYYY}${MM}`, 'hex');
5
};

1
const getQQ = (date: Date): string => {
2
  const month = Number(getMM(date));
3
4
  if (month >= 1 && month <= 3) return '01';
5
  else if (month >= 4 && month <= 6) return '02';
6
  else if (month >= 7 && month <= 9) return '03';
7
  else return '04';
8
};
9
10
const buildId = (key: string, date: Date): Buffer => {
11
  const [YYYY] = date.toISOString().split('-');
12
  const QQ = getQQ(date);
13
  
14
  return Buffer.from(`${key}${YYYY}${QQ}`, 'hex');
15
};

1
type SchemaV5R0 = {
2
  _id: Buffer;
3
  items: Array<{
4
    date: Date;
5
    a?: number;
6
    n?: number;
7
    p?: number;
8
    r?: number;
9
  }>;
10
};

1
const opeartion = {
2
  updateOne: {
3
    filter: { _id: buildId(event.key, event.date) },
4
    update: {
5
      $push: {
6
        items: {
7
          date: event.date,
8
          a: event.approved,
9
          n: event.noFunds,
10
          p: event.pending,
11
          r: event.rejected,
12
        },
13
      },
14
    },
15
    upsert: true,
16
  },
17
};

1
const pipeline = [
2
  {
3
    $match: {
4
      _id: {
5
        $gte: buildId(request.key, Date.now() - oneYear),
6
        $lte: buildId(request.key, Date.now()),
7
      },
8
    },
9
  },
10
  {
11
    $unwind: {
12
      path: '$items',
13
    },
14
  },
15
  {
16
    $match: {
17
      'items.date': { $gte: Date.now() - oneYear, $lt: Date.now() },
18
    },
19
  },
20
  {
21
    $group: {
22
      _id: null,
23
      approved: { $sum: '$items.a' },
24
      noFunds: { $sum: '$items.n' },
25
      pending: { $sum: '$items.p' },
26
      rejected: { $sum: '$items.r' },
27
    },
28
  },
29
  { $project: { _id: 0 } },
30
];

1
type SchemaV5R0 = {
2
  _id: Buffer;
3
  items: Array<{
4
    date: Date;
5
    a?: number;
6
    n?: number;
7
    p?: number;
8
    r?: number;
9
  }>;
10
};

1
const sumIfItemExists = itemsArray.buildResultIfItemExists(event);
2
const returnItemsOrCreateNew = itemsArray.buildItemsOrCreateNew(event);
3
const operation = {
4
  updateOne: {
5
    filter: {
6
      _id: buildId(event.key, event.date),
7
    },
8
    update: [
9
      { $set: { result: sumIfItemExists } },
10
      { $set: { items: returnItemsOrCreateNew } },
11
      { $unset: ['result'] },
12
    ],
13
    upsert: true,
14
  },
15
};

1
const result = items.reduce(
2
  (accumulator, element) => {
3
    if (element.date === event.date) {
4
      element.a += event.a;
5
      element.n += event.n;
6
      element.p += event.p;
7
      element.r += event.r;
8
9
      accumulator.found = true;
10
    }
11
12
    accumulator.items.push(element);
13
14
    return accumulator;
15
  },
16
  { found: false, items: [] }
17
);

1
let items = [];
2
3
if (result.found == true) {
4
  items = result.items;
5
} else {
6
  items = result.items.concat([event]);
7
}

1
const pipeline = [
2
  {
3
    $match: {
4
      _id: {
5
        $gte: buildId(request.key, Date.now() - oneYear),
6
        $lte: buildId(request.key, Date.now()),
7
      },
8
    },
9
  },
10
  {
11
    $unwind: {
12
      path: '$items',
13
    },
14
  },
15
  {
16
    $match: {
17
      'items.date': { $gte: Date.now() - oneYear, $lt: Date.now() },
18
    },
19
  },
20
  {
21
    $group: {
22
      _id: null,
23
      approved: { $sum: '$items.a' },
24
      noFunds: { $sum: '$items.n' },
25
      pending: { $sum: '$items.p' },
26
      rejected: { $sum: '$items.r' },
27
    },
28
  },
29
  { $project: { _id: 0 } },
30
];

1
type SchemaV5R0 = {
2
  _id: Buffer;
3
  items: Array<{
4
    date: Date;
5
    a?: number;
6
    n?: number;
7
    p?: number;
8
    r?: number;
9
  }>;
10
};

1
const sumIfItemExists = itemsArray.buildResultIfItemExists(event);
2
const returnItemsOrCreateNew = itemsArray.buildItemsOrCreateNew(event);
3
const operation = {
4
  updateOne: {
5
    filter: {
6
      _id: buildId(event.key, event.date),
7
    },
8
    update: [
9
      { $set: { result: sumIfItemExists } },
10
      { $set: { items: returnItemsOrCreateNew } },
11
      { $unset: ['result'] },
12
    ],
13
    upsert: true,
14
  },
15
};

1
const pipeline = [
2
  { $match: docsFromKeyBetweenDate },
3
  { $addFields: itemsReduceAccumulator },
4
  { $group: groupSumStatus },
5
  { $project: { _id: 0 } },
6
];

1
const totals = items.reduce(
2
  (accumulator, element) => {
3
    if (element.date > (Date.now() - oneYear) && element.date < Date.now()) {
4
      accumulator.a += element.a;
5
      accumulator.n += element.n;
6
      accumulator.p += element.p;
7
      accumulator.r += element.r;
8
    }
9
10
    return accumulator;
11
  },
12
  { a: 0, n: 0, p: 0, r: 0 }
13
);

1
const groupSumStatus = {
2
  _id: null,
3
  approved: { $sum: '$items.a' },
4
  noFunds: { $sum: '$items.n' },
5
  pending: { $sum: '$items.p' },
6
  rejected: { $sum: '$items.r' },
7
};

1
type SchemaV5R1 = {
2
  _id: Buffer;
3
  totals: {
4
    a?: number;
5
    n?: number;
6
    p?: number;
7
    r?: number;
8
  };
9
  items: Array<{
10
    date: Date;
11
    a?: number;
12
    n?: number;
13
    p?: number;
14
    r?: number;
15
  }>;
16
};

1
const newReportFields = itemsArray.buildNewTotals(event);
2
const sumIfItemExists = itemsArray.buildResultIfItemExists(event);
3
const returnItemsOrCreateNew = itemsArray.buildItemsOrCreateNew(event);
4
const operation = {
5
  updateOne: {
6
    filter: {
7
      _id: buildId(event.key, event.date),
8
    },
9
    update: [
10
      { $set: newReportFields },
11
      { $set: { result: sumIfItemExists } },
12
      { $set: { items: returnItemsOrCreateNew } },
13
      { $unset: ['result'] },
14
    ],
15
    upsert: true,
16
  },
17
};

1
if (totals.a != null) totals.a += event.a;
2
else totals.a = event.a;
3
4
if (totals.n != null) totals.n += event.n;
5
else totals.n = event.n;
6
7
if (totals.p != null) totals.p += event.p;
8
else totals.p = event.p;
9
10
if (totals.r != null) totals.r += event.r;
11
else totals.r = event.r;

1
const pipeline = [
2
  { $match: docsFromKeyBetweenDate },
3
  { $addFields: itemsReduceAccumulator },
4
  { $group: groupSumStatus },
5
  { $project: { _id: 0 } },
6
];

1
let totals;
2
3
if (documentQuarterWithinReportDateRage) {
4
  totals = document.totals;
5
} else {
6
  totals = document.items.reduce(
7
    (accumulator, element) => {
8
      if (element.date > Date.now() - oneYear && element.date < Date.now()) {
9
        accumulator.a += element.a;
10
        accumulator.n += element.n;
11
        accumulator.p += element.p;
12
        accumulator.r += element.r;
13
      }
14
15
      return accumulator;
16
    },
17
    { a: 0, n: 0, p: 0, r: 0 }
18
  );
19
}