historian: Rename the parser module to gossipd

We were getting a couple of path/import conflicts, renaming just to be
safe.

historian/cli/common.py

@@ -5,7 +5,7 @@ import os
 from common import Base
 import io
 from pyln.proto.primitives import varint_decode
-from parser import parse
+from gossipd import parse
 import click
 import bz2
 

historian/cli/db.py

@@ -1,7 +1,7 @@
 import click
 from common import NodeAnnouncement, ChannelAnnouncement, ChannelUpdate
 from tqdm import tqdm
-from parser import parse
+from gossipd import parse
 from cli.common import db_session, default_db
 
 

historian/common.py

@@ -2,7 +2,7 @@ from binascii import hexlify
 from datetime import datetime
 from sqlalchemy.ext.declarative import declarative_base
 from sqlalchemy import Column, BigInteger, SmallInteger, DateTime, LargeBinary
-import parser
+import gossipd
 from contextlib import contextmanager
 from sqlalchemy import create_engine
 from sqlalchemy.orm import sessionmaker
@@ -27,7 +27,7 @@ class ChannelUpdate(Base):
     raw = Column(LargeBinary)
 
     @classmethod
-    def from_gossip(cls, gcu: parser.ChannelUpdate,
+    def from_gossip(cls, gcu: gossipd.ChannelUpdate,
                     raw: bytes) -> 'ChannelUpdate':
         assert(raw[:2] == b'\x01\x02')
         self = ChannelUpdate()
@@ -53,7 +53,7 @@ class ChannelAnnouncement(Base):
     raw = Column(LargeBinary)
 
     @classmethod
-    def from_gossip(cls, gca: parser.ChannelAnnouncement,
+    def from_gossip(cls, gca: gossipd.ChannelAnnouncement,
                     raw: bytes) -> 'ChannelAnnouncement':
         assert(raw[:2] == b'\x01\x00')
         self = ChannelAnnouncement()
@@ -76,7 +76,7 @@ class NodeAnnouncement(Base):
     raw = Column(LargeBinary)
 
     @classmethod
-    def from_gossip(cls, gna: parser.NodeAnnouncement,
+    def from_gossip(cls, gna: gossipd.NodeAnnouncement,
                     raw: bytes) -> 'NodeAnnouncement':
         assert(raw[:2] == b'\x01\x01')
         self = NodeAnnouncement()

historian/historian.py

@@ -1,7 +1,6 @@
 #!/usr/bin/env python3
 from inotify import constants
 from inotify.adapters import Inotify
-from parser import parse
 from pyln.client import Plugin
 from sqlalchemy import create_engine
 from sqlalchemy import desc
@@ -9,7 +8,7 @@ from sqlalchemy.orm import sessionmaker
 from threading import Thread
 from common import Base, ChannelAnnouncement, ChannelUpdate, NodeAnnouncement
 import logging
-import parser
+import gossipd
 import struct
 import time
 
@@ -152,7 +151,7 @@ class Flusher(Thread):
 
     def store(self, raw: bytes) -> None:
         try:
-            msg = parse(raw)
+            msg = gossipd.parse(raw)
             cls = None
             if isinstance(msg, parser.ChannelUpdate):
                 cls = ChannelUpdate