wehub-resource-sync
124 lines
2.9 KiB
Go
124 lines
2.9 KiB
Go
|
|
package pocketbase
|
|
|
|
import (
|
|
"bytes"
|
|
"encoding/json"
|
|
"fmt"
|
|
"io"
|
|
"net/http"
|
|
)
|
|
|
|
func (c *PocketBaseClient) parseResponse(resp *http.Response, target interface{}) error {
|
|
body, err := io.ReadAll(resp.Body)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
return json.Unmarshal(body, target)
|
|
}
|
|
|
|
func (c *PocketBaseClient) createRecord(collection string, data interface{}) error {
|
|
jsonData, err := json.Marshal(data)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
req, err := http.NewRequest("POST",
|
|
fmt.Sprintf("%s/api/collections/%s/records", c.baseURL, collection),
|
|
bytes.NewBuffer(jsonData))
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
// No authentication header needed
|
|
req.Header.Set("Content-Type", "application/json")
|
|
|
|
resp, err := c.httpClient.Do(req)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
defer resp.Body.Close()
|
|
|
|
if resp.StatusCode != http.StatusOK && resp.StatusCode != http.StatusCreated {
|
|
// Read response body for better error details
|
|
bodyBytes, _ := io.ReadAll(resp.Body)
|
|
bodyString := string(bodyBytes)
|
|
|
|
fmt.Printf("Failed to create record in %s collection. Status: %d, Response: %s\n",
|
|
collection, resp.StatusCode, bodyString)
|
|
|
|
return fmt.Errorf("failed to create record in %s, status: %d, response: %s",
|
|
collection, resp.StatusCode, bodyString)
|
|
}
|
|
|
|
return nil
|
|
}
|
|
|
|
func (c *PocketBaseClient) updateRecord(collection string, recordID string, data interface{}) error {
|
|
jsonData, err := json.Marshal(data)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
req, err := http.NewRequest("PATCH",
|
|
fmt.Sprintf("%s/api/collections/%s/records/%s", c.baseURL, collection, recordID),
|
|
bytes.NewBuffer(jsonData))
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
req.Header.Set("Content-Type", "application/json")
|
|
|
|
resp, err := c.httpClient.Do(req)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
defer resp.Body.Close()
|
|
|
|
if resp.StatusCode != http.StatusOK {
|
|
bodyBytes, _ := io.ReadAll(resp.Body)
|
|
bodyString := string(bodyBytes)
|
|
|
|
fmt.Printf("Failed to update record in %s collection. Status: %d, Response: %s\n",
|
|
collection, resp.StatusCode, bodyString)
|
|
|
|
return fmt.Errorf("failed to update record in %s, status: %d, response: %s",
|
|
collection, resp.StatusCode, bodyString)
|
|
}
|
|
|
|
return nil
|
|
}
|
|
|
|
// UpdateRecord is the public method for server monitoring that preserves other fields
|
|
func (c *PocketBaseClient) UpdateRecord(collection string, id string, data map[string]interface{}) error {
|
|
jsonData, err := json.Marshal(data)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
req, err := http.NewRequest("PATCH",
|
|
fmt.Sprintf("%s/api/collections/%s/records/%s", c.baseURL, collection, id),
|
|
bytes.NewBuffer(jsonData))
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
req.Header.Set("Content-Type", "application/json")
|
|
|
|
resp, err := c.httpClient.Do(req)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
defer resp.Body.Close()
|
|
|
|
if resp.StatusCode != http.StatusOK {
|
|
return fmt.Errorf("failed to update record, status: %d", resp.StatusCode)
|
|
}
|
|
|
|
return nil
|
|
}
|
|
|
|
func (c *PocketBaseClient) GetHTTPClient() *http.Client {
|
|
return c.httpClient
|
|
} |