| 62 | } |
| 63 | |
| 64 | func (mapper *ChannelMapper) MapToChannelsAndAccess(ctx context.Context, body map[string]interface{}, oldBodyJSON string, metaMap map[string]interface{}, userCtx map[string]interface{}) (*ChannelMapperOutput, error) { |
| 65 | numberFixBody := ConvertJSONNumbers(body) |
| 66 | numberFixMetaMap := ConvertJSONNumbers(metaMap) |
| 67 | |
| 68 | result1, err := mapper.Call(ctx, numberFixBody, sgbucket.JSONString(oldBodyJSON), numberFixMetaMap, userCtx) |
| 69 | if err != nil { |
| 70 | return nil, err |
| 71 | } |
| 72 | output := result1.(*ChannelMapperOutput) |
| 73 | return output, nil |
| 74 | } |
| 75 | |
| 76 | // Javscript max integer value (https://www.ecma-international.org/ecma-262/5.1/#sec-8.5) |
| 77 | const JavascriptMaxSafeInt = int64(1<<53 - 1) |