/* NAME helpers.go DESCRIPTION helpers.go provides functionality for editing and reading bytes slices directly in order to insert/read timestamp and location data in psi. AUTHOR Saxon Milton LICENSE helpers.go is Copyright (C) 2018 the Australian Ocean Lab (AusOcean) It is free software: you can redistribute it and/or modify them under the terms of the GNU General Public License as published by the Free Software Foundation, either version 3 of the License, or (at your option) any later version. It is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for more details. You should have received a copy of the GNU General Public License along with revid in gpl.txt. If not, see http://www.gnu.org/licenses. */ package psi import ( "bytes" "encoding/binary" "errors" ) // TimeBytes takes a timestamp as an uint64 and converts to an 8 byte slice - // allows for updating of timestamp in pmt time descriptor. func TimeBytes(t uint64) []byte { var s [TimeDataSize]byte binary.BigEndian.PutUint64(s[:], t) return s[:] } // HasTime takes a psi as a byte slice and checks to see if it has a time descriptor // - if so return nil, otherwise return error func HasTime(p []byte) bool { return p[TimeTagIndx] == TimeDescTag } // HasLocation takes a psi as a byte slice and checks to see if it has a location descriptor // - if so return nil, otherwise return error func HasLocation(p []byte) bool { return p[LocationTagIndx] == LocationDescTag } // UpdateTime takes the byte slice representation of a psi-pmt as well as a time // as an integer and attempts to update the time descriptor in the pmt with the // given time if the time descriptor exists, otherwise an error is returned func UpdateTime(dst []byte, t uint64) error { if !HasTime(dst) { return errors.New("pmt does not have time descriptor, cannot update") } ts := TimeBytes(uint64(t)) for i := range dst[TimeDataIndx : TimeDataIndx+TimeDataSize] { dst[i+TimeDataIndx] = ts[i] } updateCrc(dst) return nil } // TimeFrom takes a byte slice representation of a psi-pmt and extracts it's // timestamp, returning as a uint64 if it exists, otherwise returning 0 and nil // if it does not exist func TimeFrom(p []byte) (t uint64, err error) { if !HasTime(p) { return 0, errors.New("pmt does not have a time descriptor") } t = binary.BigEndian.Uint64(p[TimeDataIndx : TimeDataIndx+TimeDataSize]) return t, nil } // LocationFrom takes a byte slice representation of a psi-pmt and extracts it's // timestamp, returning as a uint64 if it exists, otherwise returning 0 and nil // if it does not exist func LocationFrom(p []byte) (g string, err error) { if !HasLocation(p) { return "", errors.New("pmt does not have location descriptor") } gBytes := p[LocationDataIndx : LocationDataIndx+LocationDataSize] gBytes = bytes.Trim(gBytes, "\x00") g = string(gBytes) return g, nil } // LocationStrBytes take a string of location data and converts to a 32 byte slice - // easy update of slice representation of a pmt with location descriptor func LocationStrBytes(s string) []byte { var b [LocationDataSize]byte copy(b[:], s) return b[:] } // UpdateLocation takes a byte slice representation of a psi-pmt containing a location // descriptor and attempts to update the location data value with the passed string. // If the psi does not contain a location descriptor, and error is returned. func UpdateLocation(d []byte, s string) error { if !HasLocation(d) { return errors.New("pmt does not location descriptor, cannot update") } gb := LocationStrBytes(s) copy(d[LocationDataIndx:LocationDataIndx+LocationDataSize], gb) updateCrc(d) return nil } func trim(d []byte, t byte) []byte { for i, b := range d { if b == t { return d[:i] } } return d }