Surveiller les changements d'entreprises : monitoring et alertes

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56

interface MonitoredCompany {
  bceNumber: string;
  lastKnownStatus: string;
  lastKnownAddress: string;
  lastKnownName: string;
  lastChecked: Date;
}

async function checkForChanges(companies: MonitoredCompany[]) {
  const changes = [];

  for (const company of companies) {
    const response = await fetch(
      class="code-string">`https:class="code-comment">//companybelgium.be/api/companies/${company.bceNumber}`,
      { headers: { class="code-string">'X-API-Key': apiKey, class="code-string">'X-API-Secret': apiSecret } }
    );

    const current = await response.json();

    class="code-comment">// Détecter les changements
    if (current.status !== company.lastKnownStatus) {
      changes.push({
        bceNumber: company.bceNumber,
        type: class="code-string">'status',
        old: company.lastKnownStatus,
        new: current.status,
      });
    }

    if (current.address !== company.lastKnownAddress) {
      changes.push({
        bceNumber: company.bceNumber,
        type: class="code-string">'address',
        old: company.lastKnownAddress,
        new: current.address,
      });
    }

    if (current.name !== company.lastKnownName) {
      changes.push({
        bceNumber: company.bceNumber,
        type: class="code-string">'name',
        old: company.lastKnownName,
        new: current.name,
      });
    }

    class="code-comment">// Mettre à jour les données connues
    company.lastKnownStatus = current.status;
    company.lastKnownAddress = current.address;
    company.lastKnownName = current.name;
    company.lastChecked = new Date();
  }

  return changes;
}

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29

import express from class="code-string">'express';

const app = express();
app.use(express.json());

class="code-comment">// Endpoint pour recevoir les notifications
app.post(class="code-string">'/webhooks/company-changes', (req, res) => {
  const { event, data } = req.body;

  switch (event) {
    case class="code-string">'company.status_changed':
      console.log(class="code-string">`Statut modifié : ${data.bceNumber} → ${data.newStatus}`);
      class="code-comment">// Envoyer une alerte email/Slack
      notifyTeam(data);
      break;

    case class="code-string">'company.address_changed':
      console.log(class="code-string">`Adresse modifiée : ${data.bceNumber}`);
      updateCRM(data);
      break;

    case class="code-string">'company.name_changed':
      console.log(class="code-string">`Nom modifié : ${data.bceNumber}`);
      updateRecords(data);
      break;
  }

  res.status(200).json({ received: true });
});