Phase 1 Deliverable: Core Ledger Parser

Core Parser Implementation (parser.go)

package ledger

import (
    "bufio"
    "bytes"
    "errors"
    "io"
)

func NextField(data []byte, delim byte) ([]byte, []byte) {
    idx := bytes.IndexByte(data, delim)
    if idx == -1 {
        return data, nil
    }
    return data[:idx], data[idx+1:]
}

func ParseJournalStream(r io.Reader, maxCapacity int) ([]TransactionRecord, error) {
    records := make([]TransactionRecord, 0, maxCapacity)
    br := bufio.NewReader(r)

    for {
        line, err := br.ReadSlice('\n')
        if len(line) > 0 {
            line = bytes.TrimRight(line, "\r\n")
            if len(line) > 0 {
                rec := parseSingleLine(line)
                records = append(records, rec)
            }
        }
        if err != nil {
            if errors.Is(err, io.EOF) { break }
            return records, err
        }
    }
    return records, nil
}

โจทย์: ประกาศ Struct TransactionRecord ในแพ็กเกจ ledger ให้มีขนาด 48 ไบต์ Aligned 8 ไบต์ โดยเรียงฟิลด์ดังนี้: Timestamp int64, AmountCents int64, TxID [12]byte, AccountSrc [10]byte, AccountDst [10]byte, Currency [3]byte, Status uint8 และ _ [4]byte

โจทย์: เขียนฟังก์ชัน ExtractThreeFields(line []byte) (f1, f2, f3 []byte, ok bool) โดยใช้ bytes.IndexByte แยกข้อมูลที่มีตัวคั่น ',' จำนวน 3 ฟิลด์ หากพบไม่ครบ 3 ฟิลด์ ให้คืน nil, nil, nil, false