296
ctx context.Context,
297
request *p.InternalForkHistoryBranchRequest,
299
>
forkB := request.ForkBranchInfo
300
>
treeInfoBlob := request.TreeInfo
301
>
newBranchIdBytes, err := primitives.ParseUUID(request.NewBranchID)
302
>
if err != nil {
303
return err
304
}
305
>
treeIDBytes, err := primitives.ParseUUID(forkB.GetTreeId())
history_store.go
306
>
if err != nil {
307
return err
308
}
309
311
>
ShardID: request.ShardID,
312
>
TreeID: treeIDBytes,
313
>
BranchID: newBranchIdBytes,
314
>
Data: treeInfoBlob.Data,
315
>
DataEncoding: treeInfoBlob.EncodingType.String(),
316
>
}
317
>
318
>
result, err := m.DB.InsertIntoHistoryTree(ctx, row)
319
>
if err != nil {
320
return err
321
}
322
324
>
if err != nil {
325
return err
326
}
328
return fmt.Errorf("expected 1 or 2 row to be affected for tree table, got %v", rowsAffected)
329
}
331
}
332