2023-05-10 02:37:58 +08:00
|
|
|
package msgpatch
|
|
|
|
|
|
|
|
import (
|
|
|
|
"encoding/json"
|
|
|
|
"github.com/iMDT/bbb-graphql-middleware/internal/common"
|
|
|
|
"github.com/mattbaird/jsonpatch"
|
|
|
|
log "github.com/sirupsen/logrus"
|
|
|
|
"io/ioutil"
|
|
|
|
"os"
|
|
|
|
"path/filepath"
|
|
|
|
)
|
|
|
|
|
|
|
|
var cacheDir = os.TempDir() + "/graphql-middleware-cache/"
|
2023-05-25 06:31:31 +08:00
|
|
|
var minLengthToPatch = 250 //250 chars
|
|
|
|
var minShrinkToUsePatch = 0.5 //50% percent
|
2023-05-10 02:37:58 +08:00
|
|
|
|
2023-05-25 21:15:02 +08:00
|
|
|
func getConnPath(connectionId string) string {
|
|
|
|
return cacheDir + connectionId
|
2023-05-10 02:37:58 +08:00
|
|
|
}
|
|
|
|
|
2024-04-06 22:43:36 +08:00
|
|
|
func getSubscriptionCacheDirPath(
|
|
|
|
bConn *common.BrowserConnection,
|
|
|
|
subscriptionId string,
|
|
|
|
createIfNotExists bool) (string, error) {
|
2023-05-10 02:37:58 +08:00
|
|
|
//Using SessionToken as path to reinforce security (once connectionId repeats on restart of middleware)
|
2023-05-25 21:15:02 +08:00
|
|
|
connectionPatchCachePath := getConnPath(bConn.Id) + "/" + bConn.SessionToken + "/"
|
2023-05-10 02:37:58 +08:00
|
|
|
subscriptionCacheDirPath := connectionPatchCachePath + subscriptionId + "/"
|
|
|
|
_, err := os.Stat(subscriptionCacheDirPath)
|
|
|
|
if err != nil {
|
|
|
|
if os.IsNotExist(err) && createIfNotExists {
|
|
|
|
err = os.MkdirAll(subscriptionCacheDirPath, 0755)
|
|
|
|
if err != nil {
|
2024-04-06 22:43:36 +08:00
|
|
|
log.Errorf("Error on create cache directory: %v", err)
|
2023-05-10 02:37:58 +08:00
|
|
|
return subscriptionCacheDirPath, nil
|
|
|
|
}
|
|
|
|
} else {
|
|
|
|
return "", err
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
return subscriptionCacheDirPath, nil
|
|
|
|
}
|
|
|
|
|
2023-05-25 21:15:02 +08:00
|
|
|
func RemoveConnCacheDir(connectionId string) {
|
|
|
|
err := os.RemoveAll(getConnPath(connectionId))
|
2023-05-25 06:31:31 +08:00
|
|
|
if err != nil {
|
|
|
|
if !os.IsNotExist(err) {
|
2024-04-06 22:43:36 +08:00
|
|
|
log.Errorf("Error while removing CLI patch cache directory: %v", err)
|
2023-05-25 06:31:31 +08:00
|
|
|
}
|
2023-05-10 02:37:58 +08:00
|
|
|
return
|
|
|
|
}
|
|
|
|
|
2023-09-07 22:54:27 +08:00
|
|
|
log.Debugf("Directory of patch caches removed successfully for client %s.", connectionId)
|
2023-05-10 02:37:58 +08:00
|
|
|
}
|
|
|
|
|
2023-05-26 04:08:04 +08:00
|
|
|
func RemoveConnSubscriptionCacheFile(bConn *common.BrowserConnection, subscriptionId string) {
|
|
|
|
subsCacheDirPath, err := getSubscriptionCacheDirPath(bConn, subscriptionId, false)
|
2023-05-10 02:37:58 +08:00
|
|
|
if err == nil {
|
|
|
|
err = os.RemoveAll(subsCacheDirPath)
|
|
|
|
if err != nil {
|
|
|
|
if !os.IsNotExist(err) {
|
2024-04-06 22:43:36 +08:00
|
|
|
log.Errorf("Error while removing CLI subscription patch cache directory: %v", err)
|
2023-05-10 02:37:58 +08:00
|
|
|
}
|
|
|
|
return
|
|
|
|
}
|
|
|
|
|
2023-09-07 22:54:27 +08:00
|
|
|
log.Debugf("Directory of patch caches removed successfully for client %s, subscription %s.", bConn.Id, subscriptionId)
|
2023-05-10 02:37:58 +08:00
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
func ClearAllCaches() {
|
2023-05-25 21:15:02 +08:00
|
|
|
info, err := os.Stat(cacheDir)
|
|
|
|
if err == nil && info.IsDir() {
|
|
|
|
filepath.Walk(cacheDir, func(path string, info os.FileInfo, err error) error {
|
|
|
|
if err != nil {
|
2023-12-15 01:01:47 +08:00
|
|
|
log.Debugf("Cache dir was removed previously (probably user disconnected): %q: %v\n", path, err)
|
2023-05-25 21:15:02 +08:00
|
|
|
return err
|
|
|
|
}
|
2023-05-10 02:37:58 +08:00
|
|
|
|
2023-05-25 21:15:02 +08:00
|
|
|
if info.IsDir() && path != cacheDir {
|
|
|
|
os.RemoveAll(path)
|
|
|
|
}
|
|
|
|
return nil
|
|
|
|
})
|
|
|
|
}
|
2023-05-10 02:37:58 +08:00
|
|
|
}
|
|
|
|
|
2024-04-06 22:43:36 +08:00
|
|
|
func fileExists(filename string) bool {
|
|
|
|
_, err := os.Stat(filename)
|
|
|
|
return !os.IsNotExist(err)
|
|
|
|
}
|
|
|
|
|
|
|
|
func PatchMessage(
|
|
|
|
receivedMessage *map[string]interface{},
|
|
|
|
queryId string,
|
|
|
|
dataKey string,
|
|
|
|
dataAsJson []byte,
|
|
|
|
bConn *common.BrowserConnection,
|
|
|
|
cacheKey string,
|
|
|
|
lastDataChecksum uint32,
|
|
|
|
currDataChecksum uint32) {
|
|
|
|
|
|
|
|
if lastDataChecksum != 0 {
|
|
|
|
common.JsonPatchBenchmarkingStarted(cacheKey)
|
|
|
|
defer common.JsonPatchBenchmarkingCompleted(cacheKey)
|
|
|
|
}
|
|
|
|
|
|
|
|
//Avoid other routines from processing the same JsonPatch
|
|
|
|
common.GlobalCacheLocks.Lock(cacheKey)
|
|
|
|
jsonDiffPatch, jsonDiffPatchExists := common.GetJsonPatchCache(cacheKey)
|
|
|
|
if jsonDiffPatchExists {
|
|
|
|
//Unlock immediately once the cache was already created by other routine
|
|
|
|
common.GlobalCacheLocks.Unlock(cacheKey)
|
|
|
|
} else {
|
|
|
|
//It will create the cache and then Unlock (others will wait to benefit from this cache)
|
|
|
|
defer common.GlobalCacheLocks.Unlock(cacheKey)
|
|
|
|
}
|
|
|
|
|
2023-05-10 02:37:58 +08:00
|
|
|
var receivedMessageMap = *receivedMessage
|
|
|
|
|
2024-02-02 23:36:27 +08:00
|
|
|
fileCacheDirPath, err := getSubscriptionCacheDirPath(bConn, queryId, true)
|
|
|
|
if err != nil {
|
|
|
|
log.Errorf("Error on get Client/Subscription cache path: %v", err)
|
2023-05-10 02:37:58 +08:00
|
|
|
return
|
|
|
|
}
|
2024-02-02 23:36:27 +08:00
|
|
|
filePath := fileCacheDirPath + dataKey + ".json"
|
2023-05-10 02:37:58 +08:00
|
|
|
|
2024-04-06 22:43:36 +08:00
|
|
|
if !jsonDiffPatchExists {
|
|
|
|
if currDataChecksum == lastDataChecksum {
|
|
|
|
//Content didn't change, set message as null to avoid sending it to the browser
|
|
|
|
//This case is usual when the middleware reconnects with Hasura and receives the data again
|
|
|
|
*receivedMessage = nil
|
|
|
|
} else {
|
|
|
|
//Content was changed, creating json patch
|
|
|
|
//If data is small (< minLengthToPatch) it's not worth creating the patch
|
|
|
|
if len(string(dataAsJson)) > minLengthToPatch {
|
|
|
|
if lastContent, lastContentErr := ioutil.ReadFile(filePath); lastContentErr == nil && string(lastContent) != "" {
|
|
|
|
if diffPatch, diffPatchErr := jsonpatch.CreatePatch(lastContent, dataAsJson); diffPatchErr == nil {
|
|
|
|
if jsonDiffPatch, jsonDiffPatchErr := json.Marshal(diffPatch); jsonDiffPatchErr == nil {
|
|
|
|
common.StoreJsonPatchCache(cacheKey, jsonDiffPatch)
|
|
|
|
} else {
|
|
|
|
log.Errorf("Error marshaling patch array: %v", err)
|
|
|
|
}
|
|
|
|
} else {
|
|
|
|
log.Errorf("Error creating JSON patch: %v\n%v", diffPatchErr, string(dataAsJson))
|
|
|
|
}
|
2023-05-25 06:31:31 +08:00
|
|
|
}
|
2023-05-10 02:37:58 +08:00
|
|
|
}
|
2024-02-02 23:36:27 +08:00
|
|
|
}
|
2024-04-06 22:43:36 +08:00
|
|
|
}
|
2023-05-25 06:31:31 +08:00
|
|
|
|
2024-04-06 22:43:36 +08:00
|
|
|
//Use patch if the length is {minShrinkToUsePatch}% smaller than the original msg
|
|
|
|
if jsonDiffPatch != nil && float64(len(string(jsonDiffPatch)))/float64(len(string(dataAsJson))) < minShrinkToUsePatch {
|
|
|
|
//Modify receivedMessage to include the Patch and remove the previous data
|
|
|
|
//The key of the original message is kept to avoid errors (Apollo-client expects to receive this prop)
|
|
|
|
receivedMessageMap["payload"] = map[string]interface{}{
|
|
|
|
"data": map[string]interface{}{
|
|
|
|
"patch": json.RawMessage(jsonDiffPatch),
|
|
|
|
dataKey: json.RawMessage("[]"),
|
|
|
|
},
|
|
|
|
}
|
|
|
|
*receivedMessage = receivedMessageMap
|
|
|
|
}
|
|
|
|
|
|
|
|
//Store current result to be used to create json patch in the future
|
|
|
|
if len(string(dataAsJson)) > minLengthToPatch || fileExists(filePath) {
|
|
|
|
errWritingOutput := ioutil.WriteFile(filePath, dataAsJson, 0644)
|
|
|
|
if errWritingOutput != nil {
|
|
|
|
log.Errorf("Error on trying to write cache of json diff: %v", errWritingOutput)
|
2023-05-10 02:37:58 +08:00
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|