使用Firestore云函数：获取事件中的文档快照

小伙伴们有没有觉得学习Golang很有意思？有意思就对了！今天就给大家带来《使用Firestore云函数：获取事件中的文档快照》，以下内容将会涉及到，若是在学习中对其中部分知识点有疑问，或许看了本文就能帮到你！

我正在监听集合文档的更改事件，只是转储我收到的内容：

func forwarduserchanged(ctx context.context, e cloudfn.firestoreevent) error {
    raw, err := json.marshal(e.value.fields)
    if err != nil {
        return err
    }
    fmt.println(string(raw))

    return nil
}

其中 firestoreevent 是自定义结构：

// firestoreevent is the payload of a firestore event.
type firestoreevent struct {
    oldvalue   firestorevalue `json:"oldvalue"`
    value      firestorevalue `json:"value"`
    updatemask struct {
        fieldpaths []string `json:"fieldpaths"`
    } `json:"updatemask"`
}

type firestorevalue struct {
    createtime time.time `json:"createtime"`
    fields     map[string]interface{} `json:"fields"`
    name       string                 `json:"name"`
    updatetime time.time              `json:"updatetime"`
}

我想要的是一种将 fields 解码到我的结构中的简单方法，该结构之前已保存到同一集合中。 问题是 fields 看起来相当复杂，它不仅仅是将 map[string]interface{} 简单地映射到结构体字段。例如，fields 如下所示：

{"answers":
  {"mapvalue":
    {"fields":
      {"fish-1":
        {"mapvalue":
          {"fields":{"option":{"stringvalue":"yes"},

但原始结构是

type Report struct {
  Answers map[string]Answer
}

type Answer struct {
  Option string
}

有没有一种简单的方法可以将映射反序列化到结构中？或者应该“手工”完成？

应该有一种方法可以从这些数据中获取 documentsnapshot。来自 firestore 的数据看起来像 protobuf 消息，甚至可以在 google.golang.org/genproto/googleapis/firestore/v1 的 document 结构中看到。

解决方案

在没有找到其他解决方案来处理事件字段后，我决定在这里发布我的解决方案，以防像我这样的其他人正在寻找。

请记住，我的解决方案存在一些问题，我只是还没有解决这些问题。

• 在某些时候，必须将其重构为递归调用，以便 mapvalue 和 arrayvalue 类型可以达到所需的深度。

• 它可能应该有更好的错误检查。

type FirestoreValue struct {
        CreateTime time.Time `json:"createTime"`
        // Fields is the data for this value. The type depends on the format of your
        // database. Log an interface{} value and inspect the result to see a JSON
        // representation of your database fields.
        Fields     map[string]interface{} `json:"fields"` // I changed this to a map[string]interface{} instead of the example codes interface{}
        Name       string                 `json:"name"`
        UpdateTime time.Time              `json:"updateTime"`
    }
    
    func (fv *FirestoreValue) Recombobulate(destination interface{}) error {
        result := make(map[string]interface{})
        for fieldName, infVal := range fv.Fields {
            for typeKey, val := range infVal.(map[string]interface{}) {
                switch typeKey {
                case "stringValue":
                    result[fieldName] = val
                case "booleanValue":
                    result[fieldName] = val
                case "integerValue":
                    // I saw firestore give me this once: integerValue: "1"
                    sVal, ok := val.(string)
                    if ok {
                        result[fieldName], _ = strconv.Atoi(sVal)
                    } else {
                        result[fieldName] = val
                    }
                case "doubleValue":
                    result[fieldName] = val
                case "timestampValue":
                    result[fieldName], _ = time.Parse(time.RFC3339, val.(string))
                case "referenceValue": // this is just a string for all intents and purposes
                    result[fieldName] = val
                case "nullValue":
                    // not really sure what to do with this one
                    result[fieldName] = val
                case "arrayValue":
                    elements := val.(map[string]interface{})["values"]
                    var innards []interface{}
                    for _, ele := range elements.([]interface{}) {
                        for _, eleInterf := range ele.(map[string]interface{}) {
                            innards = append(innards, eleInterf)
                        }
                    }
                    result[fieldName] = innards
                case "mapValue":
                    mapFields := val.(map[string]interface{})["fields"]
                    innards := make(map[string]interface{})
                    for mapKeyName, v := range mapFields.(map[string]interface{}) {
                        for _, innard := range v.(map[string]interface{}) {
                            innards[mapKeyName] = innard
                        }
                    }
                    result[fieldName] = innards
                case "geoPointValue": // this is just a map[string]int/float
                    innards := make(map[string]interface{})
                    for mapKeyName, v := range val.(map[string]interface{}) {
                        innards[mapKeyName] = v
                    }
                    result[fieldName] = innards
                }
            }
        }
    
        
        mapstructure.Decode(result, &destination)
        return nil
    }

今天关于《使用Firestore云函数：获取事件中的文档快照》的内容介绍就到此结束，如果有什么疑问或者建议，可以在golang学习网公众号下多多回复交流；文中若有不正之处，也希望回复留言以告知！