gistfile1.txt

func main() {
	db, db_err := OpenDatabase("net.db")

	if db_err != nil {
		log.Println("DB error:", db_err)
		os.Exit(1)
	}

	// var mh codec.MsgpackHandle
	mh := &codec.MsgpackHandle{RawToString: true}

	dec := codec.NewDecoder(os.Stdin, mh)
	var msg map[string]interface{}

	for {
		err := dec.Decode(&msg)
		if err == nil {
			priv_log, _ := msg["Private Work Log"].(string)
			// fmt.Println(reflect.TypeOf(priv_log))

			for _, line := range strings.Split(priv_log, "\n") {
				if strings.HasPrefix(line, "MSS| ") {
					entities := ExtractEntities(line)

					for _, entity := range entities {
						insert_err := InsertNameRecord(db, msg, entity)
						if insert_err != nil {
							log.Println("Insert error:", err)
							os.Exit(1)
						}
					}
				}
			}
		} else if err == io.EOF {
			break
		} else {
			log.Println(err)
			os.Exit(1)
		}
		// fmt.Println(msg.count)
	}
}