2019-01-24 16:26:36 +00:00
|
|
|
// Copyright (C) 2019 Storj Labs, Inc.
|
2018-11-12 09:14:16 +00:00
|
|
|
// See LICENSE for copying information.
|
|
|
|
|
|
|
|
package satellitedb
|
|
|
|
|
|
|
|
import (
|
2019-05-19 16:10:46 +01:00
|
|
|
"database/sql/driver"
|
|
|
|
|
2019-12-27 11:48:47 +00:00
|
|
|
"storj.io/common/storj"
|
2018-11-12 09:14:16 +00:00
|
|
|
)
|
|
|
|
|
2019-05-19 16:10:46 +01:00
|
|
|
type postgresNodeIDList storj.NodeIDList
|
|
|
|
|
|
|
|
// Value converts a NodeIDList to a postgres array
|
|
|
|
func (nodes postgresNodeIDList) Value() (driver.Value, error) {
|
|
|
|
const hextable = "0123456789abcdef"
|
|
|
|
|
|
|
|
if nodes == nil {
|
|
|
|
return nil, nil
|
|
|
|
}
|
|
|
|
if len(nodes) == 0 {
|
|
|
|
return []byte("{}"), nil
|
|
|
|
}
|
|
|
|
|
|
|
|
var wp, x int
|
|
|
|
out := make([]byte, 2+len(nodes)*(6+storj.NodeIDSize*2)-1)
|
|
|
|
|
|
|
|
x = copy(out[wp:], []byte(`{"\\x`))
|
|
|
|
wp += x
|
|
|
|
|
|
|
|
for i := range nodes {
|
|
|
|
for _, v := range nodes[i] {
|
|
|
|
out[wp] = hextable[v>>4]
|
|
|
|
out[wp+1] = hextable[v&0xf]
|
|
|
|
wp += 2
|
|
|
|
}
|
|
|
|
|
|
|
|
if i+1 < len(nodes) {
|
|
|
|
x = copy(out[wp:], []byte(`","\\x`))
|
|
|
|
wp += x
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
x = copy(out[wp:], `"}`)
|
|
|
|
wp += x
|
|
|
|
|
|
|
|
if wp != len(out) {
|
|
|
|
panic("unreachable")
|
|
|
|
}
|
|
|
|
|
|
|
|
return out, nil
|
|
|
|
}
|