The apid Instance info has to be in the request header instead of body.
diff --git a/apigee_sync.go b/apigee_sync.go index 6c63a14..97cbe70 100644 --- a/apigee_sync.go +++ b/apigee_sync.go
@@ -204,15 +204,16 @@ form := url.Values{} form.Set("grant_type", "client_credentials") form.Add("client_id", config.GetString(configConsumerKey)) - form.Add("display_name", ginstName) - form.Add("apid_instance_id", guuid) - form.Add("apid_cluster_Id", gapidConfigId) - form.Add("status", "ONLINE") - form.Add("created_at", time.Now().Format(time.RFC3339)) - form.Add("plugin_details", gpgInfo) form.Add("client_secret", config.GetString(configConsumerSecret)) req, err := http.NewRequest("POST", uri.String(), bytes.NewBufferString(form.Encode())) req.Header.Set("Content-Type", "application/x-www-form-urlencoded; param=value") + req.Header.Set("display_name", ginstName) + req.Header.Set("apid_instance_id", guuid) + req.Header.Set("apid_cluster_Id", gapidConfigId) + req.Header.Set("status", "ONLINE") + req.Header.Set("created_at", time.Now().Format(time.RFC3339)) + req.Header.Set("plugin_details", gpgInfo) + client := &http.Client{} resp, err := client.Do(req) if err != nil { @@ -479,7 +480,7 @@ } prep, err := txn.Prepare("UPDATE APID_CONFIG SET lastSequence=$1;") if err != nil { - log.Error("INSERT APID_CONFIG Failed: ", err) + log.Error("UPDATE APID_CONFIG Failed: ", err) return false } defer prep.Close()
diff --git a/apigee_sync_test.go b/apigee_sync_test.go index 2fa9e9a..25e7782 100644 --- a/apigee_sync_test.go +++ b/apigee_sync_test.go
@@ -46,10 +46,10 @@ err := req.ParseForm() Expect(err).NotTo(HaveOccurred()) Expect(req.Form.Get("grant_type")).To(Equal("client_credentials")) - Expect(req.Form.Get("status")).To(Equal("ONLINE")) - Expect(req.Form.Get("apid_cluster_Id")).To(Equal("bootstrap")) - Expect(req.Form.Get("display_name")).To(Equal("testhost")) - plinfo := []byte(req.Form.Get("plugin_details")) + Expect(req.Header.Get("status")).To(Equal("ONLINE")) + Expect(req.Header.Get("apid_cluster_Id")).To(Equal("bootstrap")) + Expect(req.Header.Get("display_name")).To(Equal("testhost")) + plinfo := []byte(req.Header.Get("plugin_details")) err = json.Unmarshal(plinfo, &plugInfo) Expect(err).NotTo(HaveOccurred()) Expect(plugInfo[0].Name).To(Equal("apidApigeeSync"))