Fix the query & ensure company gets inserted for snapshots.
diff --git a/api.go b/api.go
index 216d1bd..477eebd 100644
--- a/api.go
+++ b/api.go
@@ -118,8 +118,8 @@
FROM
APP_CREDENTIAL AS c
INNER JOIN APP AS a ON c.app_id = a.id
- INNER JOIN ALL_DEVELOPERS AS ad
- ON (ad.id = a.company_id OR ad.id = a.developer_id)
+ INNER JOIN DEVELOPER AS ad
+ ON ad.id = a.developer_id
INNER JOIN APP_CREDENTIAL_APIPRODUCT_MAPPER as mp
ON mp.appcred_id = c.id
INNER JOIN API_PRODUCT as ap ON ap.id = mp.apiprdt_id
@@ -143,8 +143,8 @@
FROM
APP_CREDENTIAL AS c
INNER JOIN APP AS a ON c.app_id = a.id
- INNER JOIN ALL_DEVELOPERS AS ad
- ON (ad.id = a.company_id OR ad.id = a.developer_id)
+ INNER JOIN COMPANY AS ad
+ ON ad.id = a.company_id
INNER JOIN APP_CREDENTIAL_APIPRODUCT_MAPPER as mp
ON mp.appcred_id = c.id
INNER JOIN API_PRODUCT as ap ON ap.id = mp.apiprdt_id
diff --git a/listener.go b/listener.go
index 8ceb9bc..8952775 100644
--- a/listener.go
+++ b/listener.go
@@ -65,6 +65,10 @@
ok = insertAPIproducts(payload.Rows, txn)
case "kms.app_credential_apiproduct_mapper":
ok = insertAPIProductMappers(payload.Rows, txn)
+ case "kms.company":
+ ok = insertCompanies(payload.Rows, txn)
+ case "kms.company_developer":
+ ok = insertCompanyDevelopers(payload.Rows, txn)
}
if !ok {
log.Error("Error encountered in Downloading Snapshot for VerifyApiKey")
