You cannot select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.

91 lines
1.6 KiB
Go

10 years ago
package main
import (
"bufio"
"database/sql"
10 years ago
"fmt"
"io"
"regexp"
"strconv"
"strings"
)
func speckStream(r io.ReadCloser, c chan exoSystem) {
defer close(c)
10 years ago
defer r.Close()
keep := regexp.MustCompile(`^\s*[\d-]`)
br := bufio.NewReader(r)
for {
line, err := br.ReadBytes('\n')
switch err {
case io.EOF:
return
case nil:
break
default:
log_error("unable to stream speck file: %v", err)
return
}
if !keep.Match(line) {
continue
}
planet := parseSpeckLine(line)
10 years ago
c <- *planet
10 years ago
}
}
type exoSystem struct {
x, y, z float64
planets int
name string
}
func (e exoSystem) Store(db *sql.DB) {
_, err := db.Exec(`
insert into planets
(name, x, y, z, planets)
values
(?, ?, ?, ?, ?)
;`, e.name, e.x, e.y, e.z, e.planets)
10 years ago
if err != nil {
log_error("%v", err)
}
}
10 years ago
func countPlanets() (int, error) {
10 years ago
row := db.QueryRow(`select count(*) from planets`)
10 years ago
var n int
err := row.Scan(&n)
return n, err
}
10 years ago
func (e exoSystem) String() string {
return fmt.Sprintf("<name: %s x: %v y: %v z: %v planets: %v>", e.name, e.x, e.y, e.z, e.planets)
10 years ago
}
func parseSpeckLine(line []byte) *exoSystem {
10 years ago
parts := strings.Split(string(line), " ")
var err error
var g errorGroup
s := new(exoSystem)
s.x, err = strconv.ParseFloat(parts[0], 64)
g.AddError(err)
s.y, err = strconv.ParseFloat(parts[1], 64)
g.AddError(err)
s.z, err = strconv.ParseFloat(parts[2], 64)
g.AddError(err)
s.planets, err = strconv.Atoi(parts[3])
g.AddError(err)
s.name = strings.TrimSpace(strings.Join(parts[7:], " "))
10 years ago
if g != nil {
log_error("%v", g)
}
return s
10 years ago
}