Added beacon.html, with some refactor.

Refactored API.
Code refactor, adding GoLand workspace with Bazel plugin.
2020-02-02 16:39:15 +08:00 · 2020-02-01 15:06:13 +08:00 · 2020-01-12 22:09:30 +08:00 · 2019-12-26 01:10:26 +08:00
35 changed files with 1464 additions and 201 deletions
--- a/.ijwb/.bazelproject
+++ b/.ijwb/.bazelproject
@ -0,0 +1,18 @@
+directories:
+  .
+
+# Automatically includes all relevant targets under the 'directories' above
+derive_targets_from_directories: true
+
+targets:
+  # If source code isn't resolving, add additional targets that compile it here
+
+additional_languages:
+  # Uncomment any additional languages you want supported
+  # dart
+  # javascript
+  # python
+  # typescript
+
+build_flags:
+  --features=pure
--- a/.ijwb/.blaze/modules/.project-data-dir.iml
+++ b/.ijwb/.blaze/modules/.project-data-dir.iml
@ -0,0 +1,11 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<module external.system.id="Blaze" type="WEB_MODULE" version="4">
+  <component name="NewModuleRootManager">
+    <content url="file://$MODULE_DIR$/../..">
+      <excludeFolder url="file://$MODULE_DIR$/.." />
+      <excludeFolder url="file://$MODULE_DIR$/../../.idea" />
+    </content>
+    <orderEntry type="inheritedJdk" />
+    <orderEntry type="sourceFolder" forTests="false" />
+  </component>
+</module>
--- a/.ijwb/.blaze/modules/.workspace.iml
+++ b/.ijwb/.blaze/modules/.workspace.iml
@ -0,0 +1,17 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<module external.system.id="Blaze" type="WEB_MODULE" version="4">
+  <component name="Go" enabled="true" />
+  <component name="NewModuleRootManager">
+    <content url="file://$MODULE_DIR$/../../..">
+      <sourceFolder url="file://$MODULE_DIR$/../../.." isTestSource="false" />
+      <excludeFolder url="file://$MODULE_DIR$/../.." />
+      <excludeFolder url="file://$MODULE_DIR$/../../../bazel-bin" />
+      <excludeFolder url="file://$MODULE_DIR$/../../../bazel-genfiles" />
+      <excludeFolder url="file://$MODULE_DIR$/../../../bazel-navigator" />
+      <excludeFolder url="file://$MODULE_DIR$/../../../bazel-out" />
+      <excludeFolder url="file://$MODULE_DIR$/../../../bazel-testlogs" />
+    </content>
+    <orderEntry type="inheritedJdk" />
+    <orderEntry type="sourceFolder" forTests="false" />
+  </component>
+</module>
--- a/.ijwb/.idea/$CACHE_FILE$
+++ b/.ijwb/.idea/$CACHE_FILE$
@ -0,0 +1,6 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project version="4">
+  <component name="NodePackageJsonFileManager">
+    <packageJsonPaths />
+  </component>
+</project>
--- a/.ijwb/.idea/.gitignore
+++ b/.ijwb/.idea/.gitignore
@ -0,0 +1,6 @@
+# Default ignored files
+/workspace.xml
+# Project exclude paths
+/.
+
+
--- a/.ijwb/.idea/.name
+++ b/.ijwb/.idea/.name
@ -0,0 +1 @@
+navigator
--- a/.ijwb/.idea/dictionaries/eve.xml
+++ b/.ijwb/.idea/dictionaries/eve.xml
@ -0,0 +1,3 @@
+<component name="ProjectDictionaryState">
+  <dictionary name="eve" />
+</component>
--- a/.ijwb/.idea/externalDependencies.xml
+++ b/.ijwb/.idea/externalDependencies.xml
@ -0,0 +1,6 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project version="4">
+  <component name="ExternalDependencies">
+    <plugin id="com.google.idea.bazel.ijwb" />
+  </component>
+</project>
--- a/.ijwb/.idea/misc.xml
+++ b/.ijwb/.idea/misc.xml
@ -0,0 +1,72 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project version="4">
+  <component name="MarkdownProjectSettings">
+    <PreviewSettings splitEditorLayout="SPLIT" splitEditorPreview="PREVIEW" useGrayscaleRendering="false" zoomFactor="1.0" maxImageWidth="0" showGitHubPageIfSynced="false" allowBrowsingInPreview="false" synchronizePreviewPosition="true" highlightPreviewType="NONE" highlightFadeOut="5" highlightOnTyping="true" synchronizeSourcePosition="true" verticallyAlignSourceAndPreviewSyncPosition="true" showSearchHighlightsInPreview="false" showSelectionInPreview="true" openRemoteLinks="true">
+      <PanelProvider>
+        <provider providerId="com.vladsch.idea.multimarkdown.editor.swing.html.panel" providerName="Default - Swing" />
+      </PanelProvider>
+    </PreviewSettings>
+    <ParserSettings gitHubSyntaxChange="false">
+      <PegdownExtensions>
+        <option name="ABBREVIATIONS" value="false" />
+        <option name="ANCHORLINKS" value="true" />
+        <option name="ASIDE" value="false" />
+        <option name="ATXHEADERSPACE" value="true" />
+        <option name="AUTOLINKS" value="true" />
+        <option name="DEFINITIONS" value="false" />
+        <option name="DEFINITION_BREAK_DOUBLE_BLANK_LINE" value="false" />
+        <option name="FENCED_CODE_BLOCKS" value="true" />
+        <option name="FOOTNOTES" value="false" />
+        <option name="HARDWRAPS" value="false" />
+        <option name="HTML_DEEP_PARSER" value="false" />
+        <option name="INSERTED" value="false" />
+        <option name="QUOTES" value="false" />
+        <option name="RELAXEDHRULES" value="true" />
+        <option name="SMARTS" value="false" />
+        <option name="STRIKETHROUGH" value="true" />
+        <option name="SUBSCRIPT" value="false" />
+        <option name="SUPERSCRIPT" value="false" />
+        <option name="SUPPRESS_HTML_BLOCKS" value="false" />
+        <option name="SUPPRESS_INLINE_HTML" value="false" />
+        <option name="TABLES" value="true" />
+        <option name="TASKLISTITEMS" value="true" />
+        <option name="TOC" value="false" />
+        <option name="WIKILINKS" value="true" />
+      </PegdownExtensions>
+      <ParserOptions>
+        <option name="COMMONMARK_LISTS" value="true" />
+        <option name="DUMMY" value="false" />
+        <option name="EMOJI_SHORTCUTS" value="true" />
+        <option name="FLEXMARK_FRONT_MATTER" value="false" />
+        <option name="GFM_LOOSE_BLANK_LINE_AFTER_ITEM_PARA" value="false" />
+        <option name="GFM_TABLE_RENDERING" value="true" />
+        <option name="GITBOOK_URL_ENCODING" value="false" />
+        <option name="GITHUB_EMOJI_URL" value="false" />
+        <option name="GITHUB_LISTS" value="false" />
+        <option name="GITHUB_WIKI_LINKS" value="true" />
+        <option name="JEKYLL_FRONT_MATTER" value="false" />
+        <option name="SIM_TOC_BLANK_LINE_SPACER" value="true" />
+      </ParserOptions>
+    </ParserSettings>
+    <HtmlSettings headerTopEnabled="false" headerBottomEnabled="false" bodyTopEnabled="false" bodyBottomEnabled="false" embedUrlContent="false" addPageHeader="true" embedImages="false" embedHttpImages="false">
+      <GeneratorProvider>
+        <provider providerId="com.vladsch.idea.multimarkdown.editor.swing.html.generator" providerName="Default Swing HTML Generator" />
+      </GeneratorProvider>
+      <headerTop />
+      <headerBottom />
+      <bodyTop />
+      <bodyBottom />
+    </HtmlSettings>
+    <CssSettings previewScheme="UI_SCHEME" cssUri="" isCssUriEnabled="false" isCssTextEnabled="false" isDynamicPageWidth="true">
+      <StylesheetProvider>
+        <provider providerId="com.vladsch.idea.multimarkdown.editor.swing.html.css" providerName="Default Swing Stylesheet" />
+      </StylesheetProvider>
+      <ScriptProviders />
+      <cssText />
+    </CssSettings>
+    <HtmlExportSettings updateOnSave="false" parentDir="$ProjectFileDir$" targetDir="$ProjectFileDir$" cssDir="" scriptDir="" plainHtml="false" imageDir="" copyLinkedImages="false" imageUniquifyType="0" targetExt="" useTargetExt="false" noCssNoScripts="false" linkToExportedHtml="true" exportOnSettingsChange="true" regenerateOnProjectOpen="false" linkFormatType="HTTP_ABSOLUTE" />
+    <LinkMapSettings>
+      <textMaps />
+    </LinkMapSettings>
+  </component>
+</project>
--- a/.ijwb/.idea/modules.xml
+++ b/.ijwb/.idea/modules.xml
@ -0,0 +1,9 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project version="4">
+  <component name="ProjectModuleManager">
+    <modules>
+      <module fileurl="file://$PROJECT_DIR$/.blaze/modules/.project-data-dir.iml" filepath="$PROJECT_DIR$/.blaze/modules/.project-data-dir.iml" />
+      <module fileurl="file://$PROJECT_DIR$/.blaze/modules/.workspace.iml" filepath="$PROJECT_DIR$/.blaze/modules/.workspace.iml" />
+    </modules>
+  </component>
+</project>
--- a/.ijwb/.idea/runConfigurations.xml
+++ b/.ijwb/.idea/runConfigurations.xml
@ -0,0 +1,18 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project version="4">
+  <component name="RunConfigurationProducerService">
+    <option name="ignoredProducers">
+      <set>
+        <option value="com.goide.execution.application.GoApplicationRunConfigurationProducer" />
+        <option value="com.goide.execution.testing.frameworks.gobench.GobenchRunConfigurationProducer" />
+        <option value="com.goide.execution.testing.frameworks.gocheck.GocheckRunConfigurationProducer" />
+        <option value="com.goide.execution.testing.frameworks.gotest.GotestRunConfigurationProducer" />
+        <option value="com.intellij.javascript.jest.JestRunConfigurationProducer" />
+        <option value="com.intellij.javascript.protractor.ProtractorRunConfigurationProducer" />
+        <option value="com.intellij.lang.javascript.buildTools.grunt.rc.GruntRunConfigurationProducer" />
+        <option value="com.intellij.lang.javascript.buildTools.gulp.rc.GulpRunConfigurationProducer" />
+        <option value="com.intellij.lang.javascript.buildTools.npm.rc.NpmRunConfigurationProducer" />
+      </set>
+    </option>
+  </component>
+</project>
--- a/.ijwb/.idea/sqldialects.xml
+++ b/.ijwb/.idea/sqldialects.xml
@ -0,0 +1,6 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project version="4">
+  <component name="SqlDialectMappings">
+    <file url="file://$PROJECT_DIR$/../schema.sql" dialect="PostgreSQL" />
+  </component>
+</project>
--- a/.ijwb/.idea/vcs.xml
+++ b/.ijwb/.idea/vcs.xml
@ -0,0 +1,6 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project version="4">
+  <component name="VcsDirectoryMappings">
+    <mapping directory="$PROJECT_DIR$/.." vcs="Git" />
+  </component>
+</project>
--- a/.ijwb/.idea/watcherTasks.xml
+++ b/.ijwb/.idea/watcherTasks.xml
@ -0,0 +1,49 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project version="4">
+  <component name="ProjectTasksOptions">
+    <TaskOptions isEnabled="true">
+      <option name="arguments" value="fmt $FilePath$" />
+      <option name="checkSyntaxErrors" value="true" />
+      <option name="description" />
+      <option name="exitCodeBehavior" value="ERROR" />
+      <option name="fileExtension" value="go" />
+      <option name="immediateSync" value="true" />
+      <option name="name" value="go fmt" />
+      <option name="output" value="$FilePath$" />
+      <option name="outputFilters">
+        <array />
+      </option>
+      <option name="outputFromStdout" value="false" />
+      <option name="program" value="$GoExecPath$" />
+      <option name="runOnExternalChanges" value="false" />
+      <option name="scopeName" value="Project Files" />
+      <option name="trackOnlyRoot" value="true" />
+      <option name="workingDir" value="$ProjectFileDir$" />
+      <envs>
+        <env name="GOROOT" value="$GOROOT$" />
+        <env name="GOPATH" value="$GOPATH$" />
+        <env name="PATH" value="$GoBinDirs$" />
+      </envs>
+    </TaskOptions>
+    <TaskOptions isEnabled="true">
+      <option name="arguments" value="run //:gazelle -- -go_prefix git.eve.moe/jackyyf/navigator" />
+      <option name="checkSyntaxErrors" value="true" />
+      <option name="description" />
+      <option name="exitCodeBehavior" value="ERROR" />
+      <option name="fileExtension" value="go" />
+      <option name="immediateSync" value="true" />
+      <option name="name" value="gazelle" />
+      <option name="output" value="" />
+      <option name="outputFilters">
+        <array />
+      </option>
+      <option name="outputFromStdout" value="false" />
+      <option name="program" value="bazel" />
+      <option name="runOnExternalChanges" value="true" />
+      <option name="scopeName" value="All Places" />
+      <option name="trackOnlyRoot" value="false" />
+      <option name="workingDir" value="$Projectpath$" />
+      <envs />
+    </TaskOptions>
+  </component>
+</project>
--- a/BUILD.bazel
+++ b/BUILD.bazel
@ -10,15 +10,18 @@ go_library(
    importpath = "git.eve.moe/jackyyf/navigator",
    visibility = ["//visibility:private"],
    deps = [
+        "//api/beacon:go_default_library",
+        "//api/beacon/v1:go_default_library",
+        "//api/navigator:go_default_library",
        "//ipgeo:go_default_library",
        "//mapping:go_default_library",
-        "@com_github_ipipdotnet_ipdb_go//:go_default_library",
+        "@com_github_sirupsen_logrus//:go_default_library",
    ],
 )

 go_binary(
    name = "navigator",
-	pure = "on",
+    data = glob(["rules/**"]),
    embed = [":go_default_library"],
    visibility = ["//visibility:public"],
 )
--- a/329
+++ b/329
@ -41,3 +41,332 @@ go_repository(
    sum = "h1:ZP11CRSzO9uOTTOVkH6yodtI3kSY69vUID8lx8B0M3s=",
    version = "v0.0.0-20191113183327-aaf7be003892",
 )
+
+go_repository(
+    name = "com_github_cockroachdb_apd",
+    importpath = "github.com/cockroachdb/apd",
+    sum = "h1:3LFP3629v+1aKXU5Q37mxmRxX/pIu1nijXydLShEq5I=",
+    version = "v1.1.0",
+)
+
+go_repository(
+    name = "com_github_coreos_go_systemd",
+    importpath = "github.com/coreos/go-systemd",
+    sum = "h1:JOrtw2xFKzlg+cbHpyrpLDmnN1HqhBfnX7WDiW7eG2c=",
+    version = "v0.0.0-20190719114852-fd7a80b32e1f",
+)
+
+go_repository(
+    name = "com_github_creack_pty",
+    importpath = "github.com/creack/pty",
+    sum = "h1:6pwm8kMQKCmgUg0ZHTm5+/YvRK0s3THD/28+T6/kk4A=",
+    version = "v1.1.7",
+)
+
+go_repository(
+    name = "com_github_davecgh_go_spew",
+    importpath = "github.com/davecgh/go-spew",
+    sum = "h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c=",
+    version = "v1.1.1",
+)
+
+go_repository(
+    name = "com_github_go_stack_stack",
+    importpath = "github.com/go-stack/stack",
+    sum = "h1:5SgMzNM5HxrEjV0ww2lTmX6E2Izsfxas4+YHWRs3Lsk=",
+    version = "v1.8.0",
+)
+
+go_repository(
+    name = "com_github_gofrs_uuid",
+    importpath = "github.com/gofrs/uuid",
+    sum = "h1:y12jRkkFxsd7GpqdSZ+/KCs/fJbqpEXSGd4+jfEaewE=",
+    version = "v3.2.0+incompatible",
+)
+
+go_repository(
+    name = "com_github_jackc_chunkreader",
+    importpath = "github.com/jackc/chunkreader",
+    sum = "h1:4s39bBR8ByfqH+DKm8rQA3E1LHZWB9XWcrz8fqaZbe0=",
+    version = "v1.0.0",
+)
+
+go_repository(
+    name = "com_github_jackc_chunkreader_v2",
+    importpath = "github.com/jackc/chunkreader/v2",
+    sum = "h1:DUwgMQuuPnS0rhMXenUtZpqZqrR/30NWY+qQvTpSvEs=",
+    version = "v2.0.0",
+)
+
+go_repository(
+    name = "com_github_jackc_pgconn",
+    importpath = "github.com/jackc/pgconn",
+    sum = "h1:6Q01OMLPPkmcCZVB9oRT6ACgo6nTEaNFQ97O79A8NuA=",
+    version = "v1.2.0",
+)
+
+go_repository(
+    name = "com_github_jackc_pgio",
+    importpath = "github.com/jackc/pgio",
+    sum = "h1:g12B9UwVnzGhueNavwioyEEpAmqMe1E/BN9ES+8ovkE=",
+    version = "v1.0.0",
+)
+
+go_repository(
+    name = "com_github_jackc_pgmock",
+    importpath = "github.com/jackc/pgmock",
+    sum = "h1:JVX6jT/XfzNqIjye4717ITLaNwV9mWbJx0dLCpcRzdA=",
+    version = "v0.0.0-20190831213851-13a1b77aafa2",
+)
+
+go_repository(
+    name = "com_github_jackc_pgpassfile",
+    importpath = "github.com/jackc/pgpassfile",
+    sum = "h1:/6Hmqy13Ss2zCq62VdNG8tM1wchn8zjSGOBJ6icpsIM=",
+    version = "v1.0.0",
+)
+
+go_repository(
+    name = "com_github_jackc_pgproto3",
+    importpath = "github.com/jackc/pgproto3",
+    sum = "h1:FYYE4yRw+AgI8wXIinMlNjBbp/UitDJwfj5LqqewP1A=",
+    version = "v1.1.0",
+)
+
+go_repository(
+    name = "com_github_jackc_pgproto3_v2",
+    importpath = "github.com/jackc/pgproto3/v2",
+    sum = "h1:FApgMJ/GtaXfI0s8Lvd0kaLaRwMOhs4VH92pwkwQQvU=",
+    version = "v2.0.0",
+)
+
+go_repository(
+    name = "com_github_jackc_pgtype",
+    importpath = "github.com/jackc/pgtype",
+    sum = "h1:aZwrtaSe314VgSGmKvggULa2TavoD1jWVsxj9Zdltek=",
+    version = "v1.1.0",
+)
+
+go_repository(
+    name = "com_github_jackc_pgx_v4",
+    importpath = "github.com/jackc/pgx/v4",
+    sum = "h1:vcUwfx7/L53CmX3UKANy34iHs69+11iVuwMO+jY68bY=",
+    version = "v4.2.0",
+)
+
+go_repository(
+    name = "com_github_jackc_puddle",
+    importpath = "github.com/jackc/puddle",
+    sum = "h1:rbjAshlgKscNa7j0jAM0uNQflis5o2XUogPMVAwtcsM=",
+    version = "v1.0.0",
+)
+
+go_repository(
+    name = "com_github_konsorten_go_windows_terminal_sequences",
+    importpath = "github.com/konsorten/go-windows-terminal-sequences",
+    sum = "h1:DB17ag19krx9CFsz4o3enTrPXyIXCl+2iCXH/aMAp9s=",
+    version = "v1.0.2",
+)
+
+go_repository(
+    name = "com_github_kr_pretty",
+    importpath = "github.com/kr/pretty",
+    sum = "h1:L/CwN0zerZDmRFUapSPitk6f+Q3+0za1rQkzVuMiMFI=",
+    version = "v0.1.0",
+)
+
+go_repository(
+    name = "com_github_kr_pty",
+    importpath = "github.com/kr/pty",
+    sum = "h1:AkaSdXYQOWeaO3neb8EM634ahkXXe3jYbVh/F9lq+GI=",
+    version = "v1.1.8",
+)
+
+go_repository(
+    name = "com_github_kr_text",
+    importpath = "github.com/kr/text",
+    sum = "h1:45sCR5RtlFHMR4UwH9sdQ5TC8v0qDQCHnXt+kaKSTVE=",
+    version = "v0.1.0",
+)
+
+go_repository(
+    name = "com_github_lib_pq",
+    importpath = "github.com/lib/pq",
+    sum = "h1:LXpIM/LZ5xGFhOpXAQUIMM1HdyqzVYM13zNdjCEEcA0=",
+    version = "v1.2.0",
+)
+
+go_repository(
+    name = "com_github_mattn_go_colorable",
+    importpath = "github.com/mattn/go-colorable",
+    sum = "h1:/bC9yWikZXAL9uJdulbSfyVNIR3n3trXl+v8+1sx8mU=",
+    version = "v0.1.2",
+)
+
+go_repository(
+    name = "com_github_mattn_go_isatty",
+    importpath = "github.com/mattn/go-isatty",
+    sum = "h1:d5US/mDsogSGW37IV293h//ZFaeajb69h+EHFsv2xGg=",
+    version = "v0.0.9",
+)
+
+go_repository(
+    name = "com_github_pkg_errors",
+    importpath = "github.com/pkg/errors",
+    sum = "h1:iURUrRGxPUNPdy5/HRSm+Yj6okJ6UtLINN0Q9M4+h3I=",
+    version = "v0.8.1",
+)
+
+go_repository(
+    name = "com_github_pmezard_go_difflib",
+    importpath = "github.com/pmezard/go-difflib",
+    sum = "h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=",
+    version = "v1.0.0",
+)
+
+go_repository(
+    name = "com_github_rs_xid",
+    importpath = "github.com/rs/xid",
+    sum = "h1:mhH9Nq+C1fY2l1XIpgxIiUOfNpRBYH1kKcr+qfKgjRc=",
+    version = "v1.2.1",
+)
+
+go_repository(
+    name = "com_github_rs_zerolog",
+    importpath = "github.com/rs/zerolog",
+    sum = "h1:uPRuwkWF4J6fGsJ2R0Gn2jB1EQiav9k3S6CSdygQJXY=",
+    version = "v1.15.0",
+)
+
+go_repository(
+    name = "com_github_satori_go_uuid",
+    importpath = "github.com/satori/go.uuid",
+    sum = "h1:0uYX9dsZ2yD7q2RtLRtPSdGDWzjeM3TbMJP9utgA0ww=",
+    version = "v1.2.0",
+)
+
+go_repository(
+    name = "com_github_shopspring_decimal",
+    importpath = "github.com/shopspring/decimal",
+    sum = "h1:pntxY8Ary0t43dCZ5dqY4YTJCObLY1kIXl0uzMv+7DE=",
+    version = "v0.0.0-20180709203117-cd690d0c9e24",
+)
+
+go_repository(
+    name = "com_github_sirupsen_logrus",
+    importpath = "github.com/sirupsen/logrus",
+    sum = "h1:SPIRibHv4MatM3XXNO2BJeFLZwZ2LvZgfQ5+UNI2im4=",
+    version = "v1.4.2",
+)
+
+go_repository(
+    name = "com_github_stretchr_objx",
+    importpath = "github.com/stretchr/objx",
+    sum = "h1:Hbg2NidpLE8veEBkEZTL3CvlkUIVzuU9jDplZO54c48=",
+    version = "v0.2.0",
+)
+
+go_repository(
+    name = "com_github_stretchr_testify",
+    importpath = "github.com/stretchr/testify",
+    sum = "h1:2E4SXV/wtOkTonXsotYi4li6zVWxYlZuYNCXe9XRJyk=",
+    version = "v1.4.0",
+)
+
+go_repository(
+    name = "com_github_zenazn_goji",
+    importpath = "github.com/zenazn/goji",
+    sum = "h1:RSQQAbXGArQ0dIDEq+PI6WqN6if+5KHu6x2Cx/GXLTQ=",
+    version = "v0.9.0",
+)
+
+go_repository(
+    name = "in_gopkg_check_v1",
+    importpath = "gopkg.in/check.v1",
+    sum = "h1:qIbj1fsPNlZgppZ+VLlY7N33q108Sa+fhmuc+sWQYwY=",
+    version = "v1.0.0-20180628173108-788fd7840127",
+)
+
+go_repository(
+    name = "in_gopkg_inconshreveable_log15_v2",
+    importpath = "gopkg.in/inconshreveable/log15.v2",
+    sum = "h1:RlWgLqCMMIYYEVcAR5MDsuHlVkaIPDAF+5Dehzg8L5A=",
+    version = "v2.0.0-20180818164646-67afb5ed74ec",
+)
+
+go_repository(
+    name = "in_gopkg_yaml_v2",
+    importpath = "gopkg.in/yaml.v2",
+    sum = "h1:ZCJp+EgiOT7lHqUV2J862kp8Qj64Jo6az82+3Td9dZw=",
+    version = "v2.2.2",
+)
+
+go_repository(
+    name = "org_golang_x_crypto",
+    importpath = "golang.org/x/crypto",
+    sum = "h1:nVJ3guKA9qdkEQ3TUdXI9QSINo2CUPM/cySEvw2w8I0=",
+    version = "v0.0.0-20200109152110-61a87790db17",
+)
+
+go_repository(
+    name = "org_golang_x_net",
+    importpath = "golang.org/x/net",
+    sum = "h1:fHDIZ2oxGnUZRN6WgWFCbYBjH9uqVPRCUVUDhs0wnbA=",
+    version = "v0.0.0-20190813141303-74dc4d7220e7",
+)
+
+go_repository(
+    name = "org_golang_x_sync",
+    importpath = "golang.org/x/sync",
+    sum = "h1:8gQV6CLnAEikrhgkHFbMAEhagSSnXWGV915qUMm9mrU=",
+    version = "v0.0.0-20190423024810-112230192c58",
+)
+
+go_repository(
+    name = "org_golang_x_sys",
+    importpath = "golang.org/x/sys",
+    sum = "h1:ng0gs1AKnRRuEMZoTLLlbOd+C17zUDepwGQBb/n+JVg=",
+    version = "v0.0.0-20190826190057-c7b8b68b1456",
+)
+
+go_repository(
+    name = "org_golang_x_text",
+    importpath = "golang.org/x/text",
+    sum = "h1:tW2bmiBqwgJj/UpqtC8EpXEZVYOwU0yG4iWbprSVAcs=",
+    version = "v0.3.2",
+)
+
+go_repository(
+    name = "org_golang_x_tools",
+    importpath = "golang.org/x/tools",
+    sum = "h1:ESK9Jb5JOE+y4u+ozMQeXfMHwEHm6zVbaDQkeaj6wI4=",
+    version = "v0.0.0-20190823170909-c4a336ef6a2f",
+)
+
+go_repository(
+    name = "org_golang_x_xerrors",
+    importpath = "golang.org/x/xerrors",
+    sum = "h1:9zdDQZ7Thm29KFXgAX/+yaf3eVbP7djjWp/dXAppNCc=",
+    version = "v0.0.0-20190717185122-a985d3407aa7",
+)
+
+go_repository(
+    name = "org_uber_go_atomic",
+    importpath = "go.uber.org/atomic",
+    sum = "h1:cxzIVoETapQEqDhQu3QfnvXAV4AlzcvUCxkVUFw3+EU=",
+    version = "v1.4.0",
+)
+
+go_repository(
+    name = "org_uber_go_multierr",
+    importpath = "go.uber.org/multierr",
+    sum = "h1:HoEmRHQPVSqub6w2z2d2EOVs2fjyFRGyofhKuyDq0QI=",
+    version = "v1.1.0",
+)
+
+go_repository(
+    name = "org_uber_go_zap",
+    importpath = "go.uber.org/zap",
+    sum = "h1:ORx85nbTijNz8ljznvCMR1ZBIPKFn3jQrag10X2AsuM=",
+    version = "v1.10.0",
+)
--- a/api/beacon/BUILD.bazel
+++ b/api/beacon/BUILD.bazel
@ -0,0 +1,10 @@
+load("@io_bazel_rules_go//go:def.bzl", "go_library")
+
+go_library(
+    name = "go_default_library",
+    srcs = ["api.go"],
+    data = ["beacon.html"],
+    importpath = "git.eve.moe/jackyyf/navigator/api/beacon",
+    visibility = ["//visibility:public"],
+    deps = ["@com_github_sirupsen_logrus//:go_default_library"],
+)
--- a/api/beacon/api.go
+++ b/api/beacon/api.go
@ -0,0 +1,39 @@
+package beacon
+
+import (
+	"flag"
+	"fmt"
+	"github.com/sirupsen/logrus"
+	"io/ioutil"
+	"net/http"
+	"strconv"
+)
+
+var (
+	apiServeMux        = http.NewServeMux()
+	beaconFrontendPath = flag.String("beacon-html", "./api/beacon/beacon.html", "Path to the html file of beacon frontend")
+)
+
+func init() {
+	http.Handle("/beacon/", http.StripPrefix("/beacon", apiServeMux))
+}
+
+func RegisterApi(version string, handler http.Handler) {
+	apiServeMux.Handle(fmt.Sprintf("/%s/", version), http.StripPrefix(fmt.Sprint("/", version), handler))
+}
+
+func Initialize() {
+	content, err := ioutil.ReadFile(*beaconFrontendPath)
+	if err != nil {
+		panic(err)
+	}
+	apiServeMux.HandleFunc("/", func(w http.ResponseWriter, r *http.Request) {
+		w.Header().Set("Content-Type", "text/html; charset=utf-8")
+		w.Header().Set("Content-Length", strconv.Itoa(len(content)))
+		w.WriteHeader(200)
+		_, err := w.Write(content)
+		if err != nil {
+			logrus.WithError(err).Error("Unable to write html data")
+		}
+	})
+}
--- a/api/beacon/beacon.html
+++ b/api/beacon/beacon.html
@ -0,0 +1,256 @@
+<!DOCTYPE html>
+<html lang="en">
+	<head>
+		<meta http-equiv="Content-Type" content="text/html; charset=utf-8" />
+		<meta http-equiv="X-UA-Compatible" content="IE=edge" />
+		<meta name="viewport" content="width=device-width, initial-scale=1" />
+		<meta charset="utf-8" />
+		<title>EveEdge Speedtest</title>
+		<link rel="stylesheet" href="https://cdn.jsdelivr.net/npm/bootswatch@4.4.1/dist/cosmo/bootstrap.min.css" />
+		<link rel="stylesheet" href="https://cdn.jsdelivr.net/npm/font-awesome@4.7.0/css/font-awesome.min.css" />
+		<style>
+body {
+	padding-top: 64px;
+}
+
+.btn-animated {
+	transition: all 1s;
+	-webkit-transition: all 1s;
+	-moz-transition: all 1s;
+}
+		</style>
+	</head>
+	<body>
+		<nav class="navbar navbar-expand-lg navbar-dark bg-primary fixed-top" id="navbar">
+			<div class="container">
+				<a class="navbar-brand" href="#">EveEdge SpeedTest</a>
+				<button class="navbar-toggler" type="button" data-toggle="collapse" data-target="#navbar-collapse" aria-controls="navbarColor01" aria-expanded="false" aria-label="Toggle navigation">
+					<span class="navbar-toggler-icon"></span>
+				</button>
+				<div class="collapse navbar-collapse" id="navbar-collapse">
+					<ul class="navbar-nav mr-auto">
+					</ul>
+					<ul class="nav nav-pills navbar-nav">
+						<li class="nav-item dropdown">
+							<a href="#" class="nav-link dropdown-toggle" data-toggle="dropdown" role="button" aria-haspopup="true" aria-expanded="false">Language: EN <span class="caret"></span></a>
+							<div class="dropdown-menu" role="menu">
+								<a class="dropdown-item" href="#">English</a>
+								<a class="dropdown-item" href="zh-CN.html">简体中文</a>
+							</div>
+						</li>
+					</ul>
+				</div>
+			</div>
+		</nav>
+		<div class="container" id="alertbox"></div>
+		<div class="container jumbotron">
+			<p>Please click the button below to start speedtest.</p>
+			<button class="btn btn-primary btn-animated" id="start">Start SpeedTest</button>
+		</div>
+		<div class="container" id="result">
+			<table id="result-display" class="table table-striped table-hover">
+			</table>
+		</div>
+	</body>
+	<script language="javascript" src="https://cdn.jsdelivr.net/npm/jquery@3.4.1/dist/jquery.min.js"></script>
+	<script language="javascript" src="https://cdn.jsdelivr.net/npm/bootstrap@4.4.1/dist/js/bootstrap.min.js"></script>
+	<script language="javascript">
+		jQuery.support.cors = true;
+		(function($) {
+			const navigatorApiBase = "/beacon/v1";
+			const apiCall = function(path, args) {
+				path = navigatorApiBase + path;
+				if (args !== null && typeof args != "undefined") {
+					var data = JSON.stringify(args)
+					return $.ajax({
+						type: "POST",
+						url: path,
+						data: data,
+						dataType: "json",
+						contentType: "application/json",
+						crossDomain: true,
+					});
+				} else {
+					return $.ajax({
+						type: "GET",
+						url: path,
+						dataType: "json",
+						crossDomain: true
+					});
+				}
+			}
+			const formatSpeed = function(speed) {
+				const units = ["B/s", "KiB/s", "MiB/s", "GiB/s", "TiB/s", "PiB/s", "EiB/s"];
+				var u = 0;
+				while (speed >= 1000 && u < 6) {
+					speed /= 1024;
+					u += 1;
+				}
+				if (speed >= 999.5) {
+					return speed.toFixed(0) + " " + units[u];
+				}
+				// Already smaller than 1000
+				if (speed >= 99.5) {
+					return speed.toFixed(0) + " " + units[u];
+				}
+				// Already smaller than 100
+				if (speed >= 9.95) {
+					return speed.toFixed(1) + " " + units[u];
+				}
+				// Already smaller than 10
+				if (speed >= 0.995) {
+					return speed.toFixed(2) + " " + units[u];
+				}
+				return speed.toFixed(3) + " " + units[u];
+			}
+			const speedTest = function() {
+				const scheme = "https://";
+				const path = "/beacon.bin";
+				var started = false;
+				var pos = 0;
+				var nodes;
+				var suffix;
+				var context = {};
+				var result;
+				this.start = function(n, s) {
+					if (started) return false;
+					nodes = n;
+					suffix = s;
+					started = true;
+					pos = 0;
+					result = new Array(nodes.length);
+					doTest();
+				}
+				const startNext = function() {
+					pos ++;
+					if (pos >= nodes.length) {
+						$('#start').html('<i class="fa fa-spinner fa-spin" aria-hidden="true"></i> Sending results ...');
+						var postDict = {};
+						for (var i = 0; i < nodes.length; ++ i) {
+							postDict[nodes[i]] = result[i];
+						}
+						apiCall('/submit', postDict).done(function(data) {
+							$('#msgbox').remove();
+							$('#alertbox').html('<div class="alert alert-dismissible alert-success" id="msgbox" style="display: none;"><button type="button" class="close" data-dismiss="alert">&times;</button><span id="msg"></span></div>')
+							$('#msg').html('<i class="fa fa-check" aria-hidden="true"></i> Speed test finished :)');
+							$('#msgbox').animate({
+								"padding-top": "toggle",
+								"padding-bottom": "toggle",
+								height: "toggle"
+							}, 500)
+							page.resetButton();
+						}).fail(function(xhr, s, e) {
+							page.printApiError(xhr.responseText ? xhr.responseText : e.message);
+							page.resetButton();
+							return;
+						})
+						return;
+					}
+					context = {};
+					doTest();
+				}
+				const doTest = function() {
+					context.resultDom = $("#" + nodes[pos] + "-result");
+					context.resultDom.html('<i class="fa fa-spinner fa-spin" aria-hidden="true"></i> <span id="speed-display">Connecting to CDN ...</span>');
+					context.speedDom = $('#speed-display');
+					var endpoint = scheme + nodes[pos] + suffix + path + "?" + new Date().getTime();
+					context.xhr = new XMLHttpRequest();
+					context.xhr.addEventListener("readystatechange", function(e) {
+						if (e.target.readyState == 2) { // HEADERS_RECEIVED
+							window.clearTimeout(context.timer);
+							context.timer = window.setTimeout(function() {
+								context.xhr.abort();
+							}, 10000);
+							// We add eventListener here, to avoid this to be triggered by timed out.
+							context.xhr.addEventListener("loadend", function(e) {
+								const delta = performance.now() - context.startTime;
+								const speed = e.loaded / delta * 1000;
+								result[pos] = speed;
+								window.clearTimeout(context.timer);
+								context.resultDom.html('<i class="fa fa-check" aria-hidden="true"></i> Testing finished, average speed: ' + formatSpeed(speed));
+								startNext();
+							});
+							context.startTime = performance.now();
+							context.lastMeasure = performance.now();
+							context.lastLoaded = 0;
+							context.speedDom.html('Testing speed ...');
+						}
+					});
+					context.xhr.addEventListener("progress", function(e) {
+						const now = performance.now();
+						if (now - context.lastMeasure >= 500) {
+							const downloaded = e.loaded - context.lastLoaded;
+							const speed = downloaded / (now - context.lastMeasure) * 1000;
+							context.lastLoaded = e.loaded;
+							context.lastMeasure = now;
+							context.speedDom.html('Testing speed ' + formatSpeed(speed) + ' ...');
+						}
+					});
+					context.xhr.addEventListener("error", function(e) {
+						window.clearTimeout(context.timer);
+						result[pos] = -1;
+						context.resultDom.html('<i class="fa fa-times" aria-hidden="true"></i> CDN Request failed.')
+						startNext();
+					});
+					context.xhr.open("GET", endpoint);
+					context.xhr.send();
+					context.timer = window.setTimeout(function() {
+						context.xhr.abort();
+						result[pos] = -1;
+						context.resultDom.html('<i class="fa fa-times" aria-hidden="true"></i> Request timed out.')
+						startNext();
+					}, 10000);
+				};
+			};
+			var page = new (function() {
+				this.printApiError = function(msg) {
+					$('#msgbox').remove()
+					$('#alertbox').html('<div class="alert alert-dismissible alert-danger" id="msgbox" style="display: none;"><button type="button" class="close" data-dismiss="alert">&times;</button><span id="errormsg"></span></div>')
+					$('#errormsg').text("API Error: " + msg)
+					$('#msgbox').animate({
+						"padding-top": "toggle",
+						"padding-bottom": "toggle",
+						height: "toggle"
+					}, 500)
+				}
+				this.clearAllError = function() {
+					$('#msgbox').remove()
+				}
+				this.resetButton = function() {
+					$('#start').text('Start SpeedTest').removeAttr('disabled')
+				}
+			})();
+			$('#start').click(function() {
+				var $this = $(this);
+				page.clearAllError();
+				$this.attr('disabled', 'disabled');
+				$this.html('<i class="fa fa-spinner fa-spin" aria-hidden="true"></i> Loading CDN nodes ...');
+				$('#result-display').empty().append('<thead><tr><th style="width: 33.33333333%">Node Name</th><th>Result</th></tr></thead>')
+				apiCall("/getNodes").done(function(data) {
+					if (!Array.isArray(data.nodes)) {
+						page.printApiError("Endpoint returns expected data: " + data);
+						page.resetButton();
+						return;
+					}
+					if (typeof data.suffix != "string") {
+						page.printApiError("Endpoint returns expected data: " + data);
+						page.resetButton();
+						return;
+					}
+					var nodes = data.nodes;
+					var suffix = data.suffix;
+					$('#result-display').append('<tbody id="result-body"></tbody>');
+					for (var i = 0, body = $('#result-body'); i < nodes.length; ++ i) {
+						body.append('<tr><td id="' + nodes[i] + '-domain">' + nodes[i] + suffix + '</td><td id="' + nodes[i] + '-result">Test pending ...</td></tr>')
+					}
+					$this.html('<i class="fa fa-spinner fa-spin"></i> Starting speed tests ...');
+					new speedTest().start(nodes, suffix);
+				}).fail(function(xhr, s, e) {
+					page.printApiError(xhr.responseText ? xhr.responseText : e.message);
+					page.resetButton();
+					return;
+				})
+			})
+		})(jQuery);
+	</script>
+</html>
--- a/api/beacon/v1/BUILD.bazel
+++ b/api/beacon/v1/BUILD.bazel
@ -0,0 +1,14 @@
+load("@io_bazel_rules_go//go:def.bzl", "go_library")
+
+go_library(
+    name = "go_default_library",
+    srcs = ["api.go"],
+    importpath = "git.eve.moe/jackyyf/navigator/api/beacon/v1",
+    visibility = ["//visibility:public"],
+    deps = [
+        "//api/beacon:go_default_library",
+        "//mapping:go_default_library",
+        "//mapping/firefly:go_default_library",
+        "//utils:go_default_library",
+    ],
+)
--- a/api/beacon/v1/api.go
+++ b/api/beacon/v1/api.go
@ -0,0 +1,51 @@
+package v1
+
+import (
+	"encoding/json"
+	"fmt"
+	"git.eve.moe/jackyyf/navigator/api/beacon"
+	"git.eve.moe/jackyyf/navigator/mapping"
+	"git.eve.moe/jackyyf/navigator/mapping/firefly"
+	"git.eve.moe/jackyyf/navigator/utils"
+	"net/http"
+)
+
+var (
+	serveMux = http.NewServeMux()
+)
+
+func init() {
+	serveMux.HandleFunc("/getNodes", func(resp http.ResponseWriter, req *http.Request) {
+		host := utils.GetRemoteIP(req)
+		nodes := mapping.GetNodes()
+		if nodes == nil {
+			utils.ResponseWithJsonError(resp, http.StatusInternalServerError, "Unable to get nodes")
+			return
+		}
+		suffix := mapping.GetSuffix(host)
+		resp.Header().Set("Content-Type", "application/json")
+		resp.WriteHeader(http.StatusOK)
+		json.NewEncoder(resp).Encode(map[string]interface{}{
+			"nodes":  nodes,
+			"suffix": suffix,
+		})
+	})
+	serveMux.HandleFunc("/submit", func(resp http.ResponseWriter, req *http.Request) {
+		if req.Method != "POST" {
+			utils.ResponseWithJsonError(resp, http.StatusMethodNotAllowed, "Method is not accepted with this method.")
+			return
+		}
+		request := make(map[string]float64)
+		decoder := json.NewDecoder(req.Body)
+		if err := decoder.Decode(&request); err != nil {
+			utils.ResponseWithJsonError(resp, http.StatusBadRequest, "Malformed JSON payload.")
+			return
+		}
+		remoteIp := utils.GetRemoteIP(req)
+		go firefly.AddSpeedTestResult(remoteIp, request)
+		resp.Header().Set("Content-Type", "application/json")
+		resp.WriteHeader(http.StatusOK)
+		fmt.Fprint(resp, "true")
+	})
+	beacon.RegisterApi("v1", serveMux)
+}
--- a/api/navigator/BUILD.bazel
+++ b/api/navigator/BUILD.bazel
@ -0,0 +1,13 @@
+load("@io_bazel_rules_go//go:def.bzl", "go_library")
+
+go_library(
+    name = "go_default_library",
+    srcs = ["api.go"],
+    importpath = "git.eve.moe/jackyyf/navigator/api/navigator",
+    visibility = ["//visibility:public"],
+    deps = [
+        "//ipgeo:go_default_library",
+        "//mapping:go_default_library",
+        "//utils:go_default_library",
+    ],
+)
--- a/api/navigator/api.go
+++ b/api/navigator/api.go
@ -0,0 +1,109 @@
+package navigator
+
+import (
+	"encoding/json"
+	"fmt"
+	"git.eve.moe/jackyyf/navigator/ipgeo"
+	"git.eve.moe/jackyyf/navigator/mapping"
+	"git.eve.moe/jackyyf/navigator/utils"
+	"log"
+	"net"
+	"net/http"
+	"strings"
+)
+
+const (
+	errIPv4Only = "Navigator works for valid IPv4 only :)"
+)
+
+func init() {
+	http.HandleFunc("/healthz", func(resp http.ResponseWriter, req *http.Request) {
+		resp.WriteHeader(200)
+		resp.Write([]byte("ok"))
+	})
+
+	http.HandleFunc("/info", func(resp http.ResponseWriter, req *http.Request) {
+		var host string
+		if argIp := req.FormValue("ip"); argIp != "" {
+			host = argIp
+			if net.ParseIP(host).To4() == nil {
+				utils.ResponseWithError(resp, http.StatusPreconditionFailed, errIPv4Only)
+				return
+			}
+		} else {
+			host = utils.GetRemoteIP(req)
+		}
+		db := ipgeo.Get()
+
+		info_cn, err := db.FindInfo(host, "CN")
+		if err != nil {
+			fmt.Fprintf(resp, "IP %s not found in the database.", host)
+			return
+		}
+		info_en, err := db.FindInfo(host, "EN")
+		if err != nil {
+			fmt.Fprintf(resp, "IP %s not found in the database.", host)
+			return
+		}
+		resp.Header().Set("Content-Type", "text/plain")
+		resp.WriteHeader(http.StatusOK)
+		server := mapping.Get(host)
+		fmt.Fprintln(resp, "您的IP:", host)
+		fmt.Fprintln(resp, "数据库中IP所属位置:", utils.BuildLocation(info_cn))
+		if info_cn.IspDomain != "" {
+			fmt.Fprintln(resp, "数据库中IP所属运营商:", info_cn.IspDomain)
+		}
+		fmt.Fprintln(resp, "您被分配的CDN节点为:", server)
+		fmt.Fprintln(resp)
+		fmt.Fprintln(resp, strings.Repeat("=", 72))
+
+		fmt.Fprintln(resp, "Your IP:", host)
+		fmt.Fprintln(resp, "Location for your IP according our database:", utils.BuildLocation(info_en))
+		if info_en.IspDomain != "" {
+			fmt.Fprintln(resp, "ISP for your IP according our database:", info_en.IspDomain)
+		}
+		fmt.Fprintln(resp, "Allocated CDN node for you:", server)
+		fmt.Fprintln(resp)
+	})
+
+	http.HandleFunc("/mapping", func(resp http.ResponseWriter, req *http.Request) {
+		host := utils.GetRemoteIP(req)
+		resp.Header().Set("Content-Type", "text/plain")
+		resp.WriteHeader(http.StatusOK)
+		server := mapping.Get(host)
+		fmt.Fprint(resp, server)
+	})
+	http.HandleFunc("/getMapping", func(resp http.ResponseWriter, req *http.Request) {
+		ip := req.FormValue("ip")
+		if net.ParseIP(ip).To4() == nil {
+			utils.ResponseWithError(resp, http.StatusBadRequest, errIPv4Only)
+			return
+		}
+		resp.Header().Set("Content-Type", "text/plain")
+		resp.WriteHeader(http.StatusOK)
+		server := mapping.Get(ip)
+		log.Printf("%s => %s\n", ip, server)
+		fmt.Fprint(resp, server)
+	})
+	http.HandleFunc("/getNodes", func(resp http.ResponseWriter, req *http.Request) {
+		ip := req.FormValue("ip")
+		if net.ParseIP(ip).To4() == nil {
+			utils.ResponseWithError(resp, http.StatusBadRequest, errIPv4Only)
+			return
+		}
+		nodes := mapping.GetNodes()
+		if nodes == nil {
+			utils.ResponseWithJsonError(resp, http.StatusInternalServerError, "Unable to get nodes")
+			return
+		}
+		suffix := mapping.GetSuffix(ip)
+		resp.Header().Set("Content-Type", "application/json")
+		resp.WriteHeader(http.StatusOK)
+		jsonEncoder := json.NewEncoder(resp)
+		ret := make([]string, 0, len(nodes))
+		for _, node := range nodes {
+			ret = append(ret, node+suffix)
+		}
+		jsonEncoder.Encode(ret)
+	})
+}
--- a/go.mod
+++ b/go.mod
@ -4,5 +4,8 @@ go 1.13

 require (
 	github.com/ipipdotnet/ipdb-go v1.2.0
+	github.com/jackc/pgx/v4 v4.2.0
+	github.com/sirupsen/logrus v1.4.2
 	go.starlark.net v0.0.0-20191113183327-aaf7be003892
+	golang.org/x/crypto v0.0.0-20200109152110-61a87790db17 // indirect
 )
--- a/go.sum
+++ b/go.sum
@ -1,4 +1,133 @@
+github.com/cockroachdb/apd v1.1.0 h1:3LFP3629v+1aKXU5Q37mxmRxX/pIu1nijXydLShEq5I=
+github.com/cockroachdb/apd v1.1.0/go.mod h1:8Sl8LxpKi29FqWXR16WEFZRNSz3SoPzUzeMeY4+DwBQ=
+github.com/coreos/go-systemd v0.0.0-20190321100706-95778dfbb74e/go.mod h1:F5haX7vjVVG0kc13fIWeqUViNPyEJxv/OmvnBo0Yme4=
+github.com/coreos/go-systemd v0.0.0-20190719114852-fd7a80b32e1f/go.mod h1:F5haX7vjVVG0kc13fIWeqUViNPyEJxv/OmvnBo0Yme4=
+github.com/creack/pty v1.1.7/go.mod h1:lj5s0c3V2DBrqTV7llrYr5NG6My20zk30Fl46Y7DoTY=
+github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
+github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c=
+github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
+github.com/go-stack/stack v1.8.0/go.mod h1:v0f6uXyyMGvRgIKkXu+yp6POWl0qKG85gN/melR3HDY=
+github.com/gofrs/uuid v3.2.0+incompatible h1:y12jRkkFxsd7GpqdSZ+/KCs/fJbqpEXSGd4+jfEaewE=
+github.com/gofrs/uuid v3.2.0+incompatible/go.mod h1:b2aQJv3Z4Fp6yNu3cdSllBxTCLRxnplIgP/c0N/04lM=
 github.com/ipipdotnet/ipdb-go v1.2.0 h1:Afa0qx/SgRevzIK8Qg1TevuD5M28kFLWbzPvU+GQJ08=
 github.com/ipipdotnet/ipdb-go v1.2.0/go.mod h1:6SFLNyXDBF6q99FQvbOZJQCc2rdPrB1V5DSy4S83RSw=
+github.com/jackc/chunkreader v1.0.0 h1:4s39bBR8ByfqH+DKm8rQA3E1LHZWB9XWcrz8fqaZbe0=
+github.com/jackc/chunkreader v1.0.0/go.mod h1:RT6O25fNZIuasFJRyZ4R/Y2BbhasbmZXF9QQ7T3kePo=
+github.com/jackc/chunkreader/v2 v2.0.0 h1:DUwgMQuuPnS0rhMXenUtZpqZqrR/30NWY+qQvTpSvEs=
+github.com/jackc/chunkreader/v2 v2.0.0/go.mod h1:odVSm741yZoC3dpHEUXIqA9tQRhFrgOHwnPIn9lDKlk=
+github.com/jackc/pgconn v0.0.0-20190420214824-7e0022ef6ba3/go.mod h1:jkELnwuX+w9qN5YIfX0fl88Ehu4XC3keFuOJJk9pcnA=
+github.com/jackc/pgconn v0.0.0-20190824142844-760dd75542eb/go.mod h1:lLjNuW/+OfW9/pnVKPazfWOgNfH2aPem8YQ7ilXGvJE=
+github.com/jackc/pgconn v0.0.0-20190831204454-2fabfa3c18b7/go.mod h1:ZJKsE/KZfsUgOEh9hBm+xYTstcNHg7UPMVJqRfQxq4s=
+github.com/jackc/pgconn v1.2.0 h1:6Q01OMLPPkmcCZVB9oRT6ACgo6nTEaNFQ97O79A8NuA=
+github.com/jackc/pgconn v1.2.0/go.mod h1:GgY/Lbj1VonNaVdNUHs9AwWom3yP2eymFQ1C8z9r/Lk=
+github.com/jackc/pgio v1.0.0 h1:g12B9UwVnzGhueNavwioyEEpAmqMe1E/BN9ES+8ovkE=
+github.com/jackc/pgio v1.0.0/go.mod h1:oP+2QK2wFfUWgr+gxjoBH9KGBb31Eio69xUb0w5bYf8=
+github.com/jackc/pgmock v0.0.0-20190831213851-13a1b77aafa2 h1:JVX6jT/XfzNqIjye4717ITLaNwV9mWbJx0dLCpcRzdA=
+github.com/jackc/pgmock v0.0.0-20190831213851-13a1b77aafa2/go.mod h1:fGZlG77KXmcq05nJLRkk0+p82V8B8Dw8KN2/V9c/OAE=
+github.com/jackc/pgpassfile v1.0.0 h1:/6Hmqy13Ss2zCq62VdNG8tM1wchn8zjSGOBJ6icpsIM=
+github.com/jackc/pgpassfile v1.0.0/go.mod h1:CEx0iS5ambNFdcRtxPj5JhEz+xB6uRky5eyVu/W2HEg=
+github.com/jackc/pgproto3 v1.1.0 h1:FYYE4yRw+AgI8wXIinMlNjBbp/UitDJwfj5LqqewP1A=
+github.com/jackc/pgproto3 v1.1.0/go.mod h1:eR5FA3leWg7p9aeAqi37XOTgTIbkABlvcPB3E5rlc78=
+github.com/jackc/pgproto3/v2 v2.0.0-alpha1.0.20190420180111-c116219b62db/go.mod h1:bhq50y+xrl9n5mRYyCBFKkpRVTLYJVWeCc+mEAI3yXA=
+github.com/jackc/pgproto3/v2 v2.0.0-alpha1.0.20190609003834-432c2951c711/go.mod h1:uH0AWtUmuShn0bcesswc4aBTWGvw0cAxIJp+6OB//Wg=
+github.com/jackc/pgproto3/v2 v2.0.0-rc3/go.mod h1:ryONWYqW6dqSg1Lw6vXNMXoBJhpzvWKnT95C46ckYeM=
+github.com/jackc/pgproto3/v2 v2.0.0-rc3.0.20190831210041-4c03ce451f29/go.mod h1:ryONWYqW6dqSg1Lw6vXNMXoBJhpzvWKnT95C46ckYeM=
+github.com/jackc/pgproto3/v2 v2.0.0 h1:FApgMJ/GtaXfI0s8Lvd0kaLaRwMOhs4VH92pwkwQQvU=
+github.com/jackc/pgproto3/v2 v2.0.0/go.mod h1:ryONWYqW6dqSg1Lw6vXNMXoBJhpzvWKnT95C46ckYeM=
+github.com/jackc/pgtype v0.0.0-20190421001408-4ed0de4755e0/go.mod h1:hdSHsc1V01CGwFsrv11mJRHWJ6aifDLfdV3aVjFF0zg=
+github.com/jackc/pgtype v0.0.0-20190824184912-ab885b375b90/go.mod h1:KcahbBH1nCMSo2DXpzsoWOAfFkdEtEJpPbVLq8eE+mc=
+github.com/jackc/pgtype v0.0.0-20190828014616-a8802b16cc59/go.mod h1:MWlu30kVJrUS8lot6TQqcg7mtthZ9T0EoIBFiJcmcyw=
+github.com/jackc/pgtype v1.1.0 h1:aZwrtaSe314VgSGmKvggULa2TavoD1jWVsxj9Zdltek=
+github.com/jackc/pgtype v1.1.0/go.mod h1:5m2OfMh1wTK7x+Fk952IDmI4nw3nPrvtQdM0ZT4WpC0=
+github.com/jackc/pgx/v4 v4.0.0-20190420224344-cc3461e65d96/go.mod h1:mdxmSJJuR08CZQyj1PVQBHy9XOp5p8/SHH6a0psbY9Y=
+github.com/jackc/pgx/v4 v4.0.0-20190421002000-1b8f0016e912/go.mod h1:no/Y67Jkk/9WuGR0JG/JseM9irFbnEPbuWV2EELPNuM=
+github.com/jackc/pgx/v4 v4.0.0-pre1.0.20190824185557-6972a5742186/go.mod h1:X+GQnOEnf1dqHGpw7JmHqHc1NxDoalibchSk9/RWuDc=
+github.com/jackc/pgx/v4 v4.2.0 h1:vcUwfx7/L53CmX3UKANy34iHs69+11iVuwMO+jY68bY=
+github.com/jackc/pgx/v4 v4.2.0/go.mod h1:im3JmBxeFE7meKEgULr08kjebXQOtkr3DP1uVPHuygc=
+github.com/jackc/puddle v0.0.0-20190413234325-e4ced69a3a2b/go.mod h1:m4B5Dj62Y0fbyuIc15OsIqK0+JU8nkqQjsgx7dvjSWk=
+github.com/jackc/puddle v0.0.0-20190608224051-11cab39313c9/go.mod h1:m4B5Dj62Y0fbyuIc15OsIqK0+JU8nkqQjsgx7dvjSWk=
+github.com/jackc/puddle v1.0.0 h1:rbjAshlgKscNa7j0jAM0uNQflis5o2XUogPMVAwtcsM=
+github.com/jackc/puddle v1.0.0/go.mod h1:m4B5Dj62Y0fbyuIc15OsIqK0+JU8nkqQjsgx7dvjSWk=
+github.com/konsorten/go-windows-terminal-sequences v1.0.1/go.mod h1:T0+1ngSBFLxvqU3pZ+m/2kptfBszLMUkC4ZK/EgS/cQ=
+github.com/konsorten/go-windows-terminal-sequences v1.0.2 h1:DB17ag19krx9CFsz4o3enTrPXyIXCl+2iCXH/aMAp9s=
+github.com/konsorten/go-windows-terminal-sequences v1.0.2/go.mod h1:T0+1ngSBFLxvqU3pZ+m/2kptfBszLMUkC4ZK/EgS/cQ=
+github.com/kr/pretty v0.1.0 h1:L/CwN0zerZDmRFUapSPitk6f+Q3+0za1rQkzVuMiMFI=
+github.com/kr/pretty v0.1.0/go.mod h1:dAy3ld7l9f0ibDNOQOHHMYYIIbhfbHSm3C4ZsoJORNo=
+github.com/kr/pty v1.1.1/go.mod h1:pFQYn66WHrOpPYNljwOMqo10TkYh1fy3cYio2l3bCsQ=
+github.com/kr/pty v1.1.8/go.mod h1:O1sed60cT9XZ5uDucP5qwvh+TE3NnUj51EiZO/lmSfw=
+github.com/kr/text v0.1.0 h1:45sCR5RtlFHMR4UwH9sdQ5TC8v0qDQCHnXt+kaKSTVE=
+github.com/kr/text v0.1.0/go.mod h1:4Jbv+DJW3UT/LiOwJeYQe1efqtUx/iVham/4vfdArNI=
+github.com/lib/pq v1.0.0/go.mod h1:5WUZQaWbwv1U+lTReE5YruASi9Al49XbQIvNi/34Woo=
+github.com/lib/pq v1.1.0/go.mod h1:5WUZQaWbwv1U+lTReE5YruASi9Al49XbQIvNi/34Woo=
+github.com/lib/pq v1.2.0 h1:LXpIM/LZ5xGFhOpXAQUIMM1HdyqzVYM13zNdjCEEcA0=
+github.com/lib/pq v1.2.0/go.mod h1:5WUZQaWbwv1U+lTReE5YruASi9Al49XbQIvNi/34Woo=
+github.com/mattn/go-colorable v0.1.1/go.mod h1:FuOcm+DKB9mbwrcAfNl7/TZVBZ6rcnceauSikq3lYCQ=
+github.com/mattn/go-colorable v0.1.2/go.mod h1:U0ppj6V5qS13XJ6of8GYAs25YV2eR4EVcfRqFIhoBtE=
+github.com/mattn/go-isatty v0.0.5/go.mod h1:Iq45c/XA43vh69/j3iqttzPXn0bhXyGjM0Hdxcsrc5s=
+github.com/mattn/go-isatty v0.0.7/go.mod h1:Iq45c/XA43vh69/j3iqttzPXn0bhXyGjM0Hdxcsrc5s=
+github.com/mattn/go-isatty v0.0.8/go.mod h1:Iq45c/XA43vh69/j3iqttzPXn0bhXyGjM0Hdxcsrc5s=
+github.com/mattn/go-isatty v0.0.9/go.mod h1:YNRxwqDuOph6SZLI9vUUz6OYw3QyUt7WiY2yME+cCiQ=
+github.com/pkg/errors v0.8.1 h1:iURUrRGxPUNPdy5/HRSm+Yj6okJ6UtLINN0Q9M4+h3I=
+github.com/pkg/errors v0.8.1/go.mod h1:bwawxfHBFNV+L2hUp1rHADufV3IMtnDRdf1r5NINEl0=
+github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=
+github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
+github.com/rs/xid v1.2.1/go.mod h1:+uKXf+4Djp6Md1KODXJxgGQPKngRmWyn10oCKFzNHOQ=
+github.com/rs/zerolog v1.13.0/go.mod h1:YbFCdg8HfsridGWAh22vktObvhZbQsZXe4/zB0OKkWU=
+github.com/rs/zerolog v1.15.0/go.mod h1:xYTKnLHcpfU2225ny5qZjxnj9NvkumZYjJHlAThCjNc=
+github.com/satori/go.uuid v1.2.0/go.mod h1:dA0hQrYB0VpLJoorglMZABFdXlWrHn1NEOzdhQKdks0=
+github.com/shopspring/decimal v0.0.0-20180709203117-cd690d0c9e24 h1:pntxY8Ary0t43dCZ5dqY4YTJCObLY1kIXl0uzMv+7DE=
+github.com/shopspring/decimal v0.0.0-20180709203117-cd690d0c9e24/go.mod h1:M+9NzErvs504Cn4c5DxATwIqPbtswREoFCre64PpcG4=
+github.com/sirupsen/logrus v1.4.1/go.mod h1:ni0Sbl8bgC9z8RoU9G6nDWqqs/fq4eDPysMBDgk/93Q=
+github.com/sirupsen/logrus v1.4.2 h1:SPIRibHv4MatM3XXNO2BJeFLZwZ2LvZgfQ5+UNI2im4=
+github.com/sirupsen/logrus v1.4.2/go.mod h1:tLMulIdttU9McNUspp0xgXVQah82FyeX6MwdIuYE2rE=
+github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME=
+github.com/stretchr/objx v0.1.1/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME=
+github.com/stretchr/objx v0.2.0/go.mod h1:qt09Ya8vawLte6SNmTgCsAVtYtaKzEcn8ATUoHMkEqE=
+github.com/stretchr/testify v1.2.2/go.mod h1:a8OnRcib4nhh0OaRAV+Yts87kKdq0PP7pXfy6kDkUVs=
+github.com/stretchr/testify v1.3.0/go.mod h1:M5WIy9Dh21IEIfnGCwXGc5bZfKNJtfHm1UVUgZn+9EI=
+github.com/stretchr/testify v1.4.0 h1:2E4SXV/wtOkTonXsotYi4li6zVWxYlZuYNCXe9XRJyk=
+github.com/stretchr/testify v1.4.0/go.mod h1:j7eGeouHqKxXV5pUuKE4zz7dFj8WfuZ+81PSLYec5m4=
+github.com/zenazn/goji v0.9.0/go.mod h1:7S9M489iMyHBNxwZnk9/EHS098H4/F6TATF2mIxtB1Q=
 go.starlark.net v0.0.0-20191113183327-aaf7be003892 h1:ZP11CRSzO9uOTTOVkH6yodtI3kSY69vUID8lx8B0M3s=
 go.starlark.net v0.0.0-20191113183327-aaf7be003892/go.mod h1:c1/X6cHgvdXj6pUlmWKMkuqRnW4K8x2vwt6JAaaircg=
+go.uber.org/atomic v1.3.2/go.mod h1:gD2HeocX3+yG+ygLZcrzQJaqmWj9AIm7n08wl/qW/PE=
+go.uber.org/atomic v1.4.0/go.mod h1:gD2HeocX3+yG+ygLZcrzQJaqmWj9AIm7n08wl/qW/PE=
+go.uber.org/multierr v1.1.0/go.mod h1:wR5kodmAFQ0UK8QlbwjlSNy0Z68gJhDJUG5sjR94q/0=
+go.uber.org/zap v1.9.1/go.mod h1:vwi/ZaCAaUcBkycHslxD9B2zi4UTXhF60s6SWpuDF0Q=
+go.uber.org/zap v1.10.0/go.mod h1:vwi/ZaCAaUcBkycHslxD9B2zi4UTXhF60s6SWpuDF0Q=
+golang.org/x/crypto v0.0.0-20190308221718-c2843e01d9a2/go.mod h1:djNgcEr1/C05ACkg1iLfiJU5Ep61QUkGW8qpdssI0+w=
+golang.org/x/crypto v0.0.0-20190411191339-88737f569e3a/go.mod h1:WFFai1msRO1wXaEeE5yQxYXgSfI8pQAWXbQop6sCtWE=
+golang.org/x/crypto v0.0.0-20190820162420-60c769a6c586/go.mod h1:yigFU9vqHzYiE8UmvKecakEJjdnWj3jj499lnFckfCI=
+golang.org/x/crypto v0.0.0-20190911031432-227b76d455e7/go.mod h1:yigFU9vqHzYiE8UmvKecakEJjdnWj3jj499lnFckfCI=
+golang.org/x/crypto v0.0.0-20200109152110-61a87790db17 h1:nVJ3guKA9qdkEQ3TUdXI9QSINo2CUPM/cySEvw2w8I0=
+golang.org/x/crypto v0.0.0-20200109152110-61a87790db17/go.mod h1:LzIPMQfyMNhhGPhUkYOs5KpL4U8rLKemX1yGLhDgUto=
+golang.org/x/net v0.0.0-20190311183353-d8887717615a/go.mod h1:t9HGtf8HONx5eT2rtn7q6eTqICYqUVnKs3thJo3Qplg=
+golang.org/x/net v0.0.0-20190404232315-eb5bcb51f2a3/go.mod h1:t9HGtf8HONx5eT2rtn7q6eTqICYqUVnKs3thJo3Qplg=
+golang.org/x/net v0.0.0-20190620200207-3b0461eec859/go.mod h1:z5CRVTTTmAJ677TzLLGU+0bjPO0LkuOLi4/5GtJWs/s=
+golang.org/x/net v0.0.0-20190813141303-74dc4d7220e7/go.mod h1:z5CRVTTTmAJ677TzLLGU+0bjPO0LkuOLi4/5GtJWs/s=
+golang.org/x/sync v0.0.0-20190423024810-112230192c58/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
+golang.org/x/sys v0.0.0-20180905080454-ebe1bf3edb33/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
+golang.org/x/sys v0.0.0-20190215142949-d0b11bdaac8a/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
+golang.org/x/sys v0.0.0-20190222072716-a9d3bda3a223/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
+golang.org/x/sys v0.0.0-20190403152447-81d4e9dc473e/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
+golang.org/x/sys v0.0.0-20190412213103-97732733099d/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
+golang.org/x/sys v0.0.0-20190422165155-953cdadca894/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
+golang.org/x/sys v0.0.0-20190813064441-fde4db37ae7a/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
+golang.org/x/sys v0.0.0-20190826190057-c7b8b68b1456 h1:ng0gs1AKnRRuEMZoTLLlbOd+C17zUDepwGQBb/n+JVg=
+golang.org/x/sys v0.0.0-20190826190057-c7b8b68b1456/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
+golang.org/x/text v0.3.0/go.mod h1:NqM8EUOU14njkJ3fqMW+pc6Ldnwhi/IjpwHt7yyuwOQ=
+golang.org/x/text v0.3.2 h1:tW2bmiBqwgJj/UpqtC8EpXEZVYOwU0yG4iWbprSVAcs=
+golang.org/x/text v0.3.2/go.mod h1:bEr9sfX3Q8Zfm5fL9x+3itogRgK3+ptLWKqgva+5dAk=
+golang.org/x/tools v0.0.0-20180917221912-90fa682c2a6e/go.mod h1:n7NCudcB/nEzxVGmLbDWY5pfWTLqBcC2KZ6jyYvM4mQ=
+golang.org/x/tools v0.0.0-20190425163242-31fd60d6bfdc/go.mod h1:RgjU9mgBXZiqYHBnxXauZ1Gv1EHHAz9KjViQ78xBX0Q=
+golang.org/x/tools v0.0.0-20190823170909-c4a336ef6a2f/go.mod h1:b+2E5dAYhXwXZwtnZ6UAqBI28+e2cm9otk0dWdXHAEo=
+golang.org/x/xerrors v0.0.0-20190410155217-1f06c39b4373/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
+golang.org/x/xerrors v0.0.0-20190513163551-3ee3066db522/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
+golang.org/x/xerrors v0.0.0-20190717185122-a985d3407aa7 h1:9zdDQZ7Thm29KFXgAX/+yaf3eVbP7djjWp/dXAppNCc=
+golang.org/x/xerrors v0.0.0-20190717185122-a985d3407aa7/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
+gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
+gopkg.in/check.v1 v1.0.0-20180628173108-788fd7840127 h1:qIbj1fsPNlZgppZ+VLlY7N33q108Sa+fhmuc+sWQYwY=
+gopkg.in/check.v1 v1.0.0-20180628173108-788fd7840127/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
+gopkg.in/inconshreveable/log15.v2 v2.0.0-20180818164646-67afb5ed74ec/go.mod h1:aPpfJ7XW+gOuirDoZ8gHhLh3kZ1B08FtV2bbmy7Jv3s=
+gopkg.in/yaml.v2 v2.2.2 h1:ZCJp+EgiOT7lHqUV2J862kp8Qj64Jo6az82+3Td9dZw=
+gopkg.in/yaml.v2 v2.2.2/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI=
--- a/main.go
+++ b/main.go
@ -1,197 +1,30 @@
 package main

 import (
-	"encoding/json"
 	"flag"
-	"fmt"
-	"log"
-	"net"
-	"net/http"
-	_ "net/http/pprof"
-	"strings"
-
+	"git.eve.moe/jackyyf/navigator/api/beacon"
+	_ "git.eve.moe/jackyyf/navigator/api/beacon/v1"
+	_ "git.eve.moe/jackyyf/navigator/api/navigator"
 	"git.eve.moe/jackyyf/navigator/ipgeo"
 	"git.eve.moe/jackyyf/navigator/mapping"
-	"github.com/ipipdotnet/ipdb-go"
+	"github.com/sirupsen/logrus"
+	"log"
+	"net/http"
+	_ "net/http/pprof"
+	"os"
 )

-const (
-	errIPv4Only      = "Navigator works for valid IPv4 only :)"
-	remoteAddrHeader = "X-NAV-REMOTE-IP"
-)
-
-type errorMessage struct {
-	Error string `json:error`
-}
-
 var (
 	listen_spec = flag.String("bind", "127.0.0.1:8086", "http server bind spec")
 )

-func responseWithError(resp http.ResponseWriter, statusCode int, message string) {
-	resp.Header().Set("Content-Type", "text/plain")
-	resp.WriteHeader(statusCode)
-	resp.Write([]byte("error: " + message))
-}
-
-func responseWithJsonError(resp http.ResponseWriter, statusCode int, message string) {
-	resp.Header().Set("Content-Type", "application/json")
-	resp.WriteHeader(statusCode)
-	encoder := json.NewEncoder(resp)
-	err := encoder.Encode(&errorMessage{
-		Error: message,
-	})
-	if err != nil {
-		// This should never happen
-		panic("json marshal failed, check code")
-	}
-}
-
-func getRemoteIP(req *http.Request) string {
-	if addr := req.Header.Get(remoteAddrHeader); addr != "" {
-		if net.ParseIP(addr).To4() == nil {
-			return ""
-		}
-		return addr
-	}
-	host, _, err := net.SplitHostPort(req.RemoteAddr)
-	if err != nil {
-		return ""
-	}
-	if net.ParseIP(host).To4() == nil {
-		return ""
-	}
-	return host
-}
-
-func buildLocation(info *ipdb.CityInfo) string {
-	ret := ""
-	if info.CountryName != "" {
-		ret += info.CountryName + " "
-	}
-	if info.RegionName != "" {
-		ret += info.RegionName + " "
-	}
-	if info.CityName != "" {
-		ret += info.CityName + " "
-	}
-	return strings.TrimSpace(ret)
-}
-
 func main() {
 	flag.Parse()
+	logrus.SetReportCaller(true)
+	logrus.SetOutput(os.Stderr)
 	ipgeo.Initialize()
 	mapping.Initialize()
-
-	http.HandleFunc("/healthz", func(resp http.ResponseWriter, req *http.Request) {
-		resp.WriteHeader(200)
-		resp.Write([]byte("ok"))
-	})
-
-	http.HandleFunc("/info", func(resp http.ResponseWriter, req *http.Request) {
-		var host string
-		if argIp := req.FormValue("ip"); argIp != "" {
-			host = argIp
-			if net.ParseIP(host).To4() == nil {
-				responseWithError(resp, http.StatusPreconditionFailed, errIPv4Only)
-				return
-			}
-		} else {
-			host = getRemoteIP(req)
-		}
-		db := ipgeo.Get()
-
-		info_cn, err := db.FindInfo(host, "CN")
-		if err != nil {
-			fmt.Fprintf(resp, "IP %s not found in the database.", host)
-			return
-		}
-		info_en, err := db.FindInfo(host, "EN")
-		if err != nil {
-			fmt.Fprintf(resp, "IP %s not found in the database.", host)
-			return
-		}
-		resp.Header().Set("Content-Type", "text/plain")
-		resp.WriteHeader(http.StatusOK)
-		server := mapping.Get(host)
-		fmt.Fprintln(resp, "您的IP:", host)
-		fmt.Fprintln(resp, "数据库中IP所属位置:", buildLocation(info_cn))
-		if info_cn.IspDomain != "" {
-			fmt.Fprintln(resp, "数据库中IP所属运营商:", info_cn.IspDomain)
-		}
-		fmt.Fprintln(resp, "您被分配的CDN节点为:", server)
-		fmt.Fprintln(resp)
-		fmt.Fprintln(resp, strings.Repeat("=", 72))
-
-		fmt.Fprintln(resp, "Your IP:", host)
-		fmt.Fprintln(resp, "Location for your IP according our database:", buildLocation(info_en))
-		if info_en.IspDomain != "" {
-			fmt.Fprintln(resp, "ISP for your IP according our database:", info_en.IspDomain)
-		}
-		fmt.Fprintln(resp, "Allocated CDN node for you:", server)
-		fmt.Fprintln(resp)
-	})
-
-	http.HandleFunc("/mapping", func(resp http.ResponseWriter, req *http.Request) {
-		host := getRemoteIP(req)
-		resp.Header().Set("Content-Type", "text/plain")
-		resp.WriteHeader(http.StatusOK)
-		server := mapping.Get(host)
-		fmt.Fprint(resp, server)
-	})
-	http.HandleFunc("/getMapping", func(resp http.ResponseWriter, req *http.Request) {
-		ip := req.FormValue("ip")
-		if net.ParseIP(ip).To4() == nil {
-			responseWithError(resp, http.StatusBadRequest, errIPv4Only)
-			return
-		}
-		resp.Header().Set("Content-Type", "text/plain")
-		resp.WriteHeader(http.StatusOK)
-		server := mapping.Get(ip)
-		log.Printf("%s => %s\n", ip, server)
-		fmt.Fprint(resp, server)
-	})
-	http.HandleFunc("/getNodes", func(resp http.ResponseWriter, req *http.Request) {
-		ip := req.FormValue("ip")
-		if net.ParseIP(ip).To4() == nil {
-			responseWithError(resp, http.StatusBadRequest, errIPv4Only)
-			return
-		}
-		nodes := mapping.GetNodes()
-		if nodes == nil {
-			responseWithJsonError(resp, http.StatusInternalServerError, "Unable to get nodes")
-			return
-		}
-		suffix := mapping.GetSuffix(ip)
-		resp.Header().Set("Content-Type", "application/json")
-		resp.WriteHeader(http.StatusOK)
-		jsonEncoder := json.NewEncoder(resp)
-		ret := make([]string, 0, len(nodes))
-		for _, node := range nodes {
-			ret = append(ret, node+suffix)
-		}
-		jsonEncoder.Encode(ret)
-	})
-	clientApi := http.NewServeMux()
-	http.Handle("/client/", http.StripPrefix("/client", clientApi))
-	clientV1Api := http.NewServeMux()
-	clientApi.Handle("/v1/", http.StripPrefix("/v1", clientV1Api))
-	clientV1Api.HandleFunc("/getNodes", func(resp http.ResponseWriter, req *http.Request) {
-		host := getRemoteIP(req)
-		nodes := mapping.GetNodes()
-		if nodes == nil {
-			responseWithJsonError(resp, http.StatusInternalServerError, "Unable to get nodes")
-			return
-		}
-		suffix := mapping.GetSuffix(host)
-		resp.Header().Set("Content-Type", "application/json")
-		resp.WriteHeader(http.StatusOK)
-		jsonEncoder := json.NewEncoder(resp)
-		jsonEncoder.Encode(map[string]interface{}{
-			"nodes":  nodes,
-			"suffix": suffix,
-		})
-	})
+	beacon.Initialize()
 	log.Println("HTTP server is running on", *listen_spec)
 	http.ListenAndServe(*listen_spec, nil)
 }
--- a/mapping/BUILD.bazel
+++ b/mapping/BUILD.bazel
@ -5,5 +5,8 @@ go_library(
    srcs = ["map.go"],
    importpath = "git.eve.moe/jackyyf/navigator/mapping",
    visibility = ["//visibility:public"],
-    deps = ["//mapping/elf:go_default_library"],
+    deps = [
+        "//mapping/elf:go_default_library",
+        "//mapping/firefly:go_default_library",
+    ],
 )
--- a/mapping/elf/core.go
+++ b/mapping/elf/core.go
@ -4,11 +4,14 @@ import (
 	"flag"
 	"fmt"
 	"log"
+	"math/rand"
 	"os"
 	"os/signal"
+	"sort"
 	"sync"
 	"sync/atomic"
 	"syscall"
+	"time"

 	"go.starlark.net/starlark"
 )
@ -36,6 +39,7 @@ var (
 	reloadSignal = make(chan os.Signal)
 	pool         *threadPool
 	counter      uint64
+	rnd          = rand.New(rand.NewSource(time.Now().UnixNano()))
 )

 func newThreadPool(size int) *threadPool {
@ -139,6 +143,61 @@ func reload() {
 	parsedFunc = &globals
 }

+func getTarget(ret starlark.Value) string {
+	switch r := ret.(type) {
+	case starlark.String:
+		return string(r)
+	case *starlark.List:
+		val := r.Index(rnd.Intn(r.Len()))
+		if s, ok := val.(starlark.String); ok {
+			return string(s)
+		}
+		goto scriptError
+	case starlark.Tuple:
+		val := r.Index(rnd.Intn(r.Len()))
+		if s, ok := val.(starlark.String); ok {
+			return string(s)
+		}
+		goto scriptError
+	case *starlark.Dict:
+		values := r.Items()
+		options := make([]string, r.Len())
+		tot := int64(0)
+		for i := range values {
+			if v, ok := values[i].Index(0).(starlark.String); ok {
+				options[i] = string(v)
+			} else {
+				goto scriptError
+			}
+			if v, ok := values[i].Index(1).(starlark.Int); ok {
+				if weight, ok := v.Int64(); ok {
+					tot += weight
+				} else {
+					goto scriptError
+				}
+			} else {
+				goto scriptError
+			}
+		}
+		sort.Strings(options)
+		pos := rnd.Int63n(tot)
+		for _, option := range options {
+			w, _, _ := r.Get(starlark.String(option))
+			v, _ := w.(starlark.Int).Int64()
+			pos -= v
+			if pos < 0 {
+				return option
+			}
+		}
+		log.Println("Unexpected code execution,",
+			"check random logic for *starlark.Dict")
+		return options[len(options)-1]
+	}
+scriptError:
+	log.Println("Script returned unexpected result:", ret.String())
+	return ""
+}
+
 func GetMapping(ip string) string {
 	thread := pool.Get()
 	ret, err := starlark.Call(thread, (*parsedFunc)["getMapping"],
@ -147,11 +206,7 @@ func GetMapping(ip string) string {
 		log.Println("Starlark execute error:", err.Error())
 		return ""
 	}
-	if r, ok := ret.(starlark.String); ok {
-		return string(r)
-	}
-	log.Println("Script returned unexpected result:", ret.String())
-	return ""
+	return getTarget(ret)
 }

 func GetNodes() (res []string) {
@ -164,12 +219,11 @@ func GetNodes() (res []string) {
 	if r, ok := ret.(*starlark.List); ok {
 		res = make([]string, r.Len())
 		for i := 0; i < r.Len(); i++ {
-			v := r.Index(i)
-			if s, ok := v.(starlark.String); ok {
-				res[i] = string(s)
-			} else {
+			res[i] = getTarget(r.Index(i))
+			if res[i] == "" {
 				log.Println("Script returned unexpected result:",
 					ret.String())
+				return nil
 			}
 		}
 	} else {
--- a/mapping/firefly/BUILD.bazel
+++ b/mapping/firefly/BUILD.bazel
@ -0,0 +1,13 @@
+load("@io_bazel_rules_go//go:def.bzl", "go_library")
+
+go_library(
+    name = "go_default_library",
+    srcs = ["core.go"],
+    importpath = "git.eve.moe/jackyyf/navigator/mapping/firefly",
+    visibility = ["//visibility:public"],
+    deps = [
+        "@com_github_jackc_pgx_v4//:go_default_library",
+        "@com_github_jackc_pgx_v4//pgxpool:go_default_library",
+        "@com_github_sirupsen_logrus//:go_default_library",
+    ],
+)
--- a/mapping/firefly/core.go
+++ b/mapping/firefly/core.go
@ -0,0 +1,70 @@
+package firefly
+
+import (
+	"context"
+	"flag"
+	"github.com/jackc/pgx/v4"
+	"github.com/jackc/pgx/v4/pgxpool"
+	"github.com/sirupsen/logrus"
+)
+
+var (
+	pgsqlConn = flag.String("pgsql", "", "Connection spec for postgresql database")
+	pool      *pgxpool.Pool
+)
+
+func Initialize() {
+	var err error
+	config, err := pgxpool.ParseConfig(*pgsqlConn)
+	if err != nil {
+		panic(err)
+	}
+	if config.MaxConns == 0 {
+		config.MaxConns = 8
+	}
+	if pool, err = pgxpool.Connect(context.Background(), *pgsqlConn); err != nil {
+		panic(err)
+	}
+	if conn, err := pool.Acquire(context.Background()); err != nil {
+		panic(err)
+	} else {
+		conn.Release()
+	}
+}
+
+func AddSpeedTestResult(ip string, speed map[string]float64) {
+	conn, err := pool.Acquire(context.Background())
+	if err != nil {
+		logrus.WithError(err).Error("Unable to get database connection")
+		return
+	}
+	defer conn.Release()
+	tx, err := conn.Begin(context.Background())
+	if err != nil {
+		logrus.WithError(err).Error("Unable to start database transaction")
+		return
+	}
+	row := tx.QueryRow(context.Background(),
+		"INSERT INTO speedtest_entry (id, ip, timestamp) VALUES (DEFAULT, $1, now()) RETURNING id", ip)
+	var id int64
+	if err = row.Scan(&id); err != nil {
+		logrus.WithError(err).Error("Unable to insert new speedtest result entry")
+		_ = tx.Rollback(context.Background())
+		return
+	}
+	batch := &pgx.Batch{}
+	for name, value := range speed {
+		batch.Queue("INSERT INTO speedtest_result (entry_id, node, speed) VALUES ($1, $2, $3)",
+			id, name, value)
+	}
+	results := tx.SendBatch(context.Background(), batch)
+	if err = results.Close(); err != nil {
+		logrus.WithError(err).Error("Unable to insert speedtest results")
+		_ = tx.Rollback(context.Background())
+		return
+	}
+	if err = tx.Commit(context.Background()); err != nil {
+		logrus.WithError(err).Error("Unable to commit the database transaction")
+		_ = tx.Rollback(context.Background())
+	}
+}
--- a/mapping/map.go
+++ b/mapping/map.go
@ -3,12 +3,12 @@ package mapping
 import (
 	"flag"
 	"git.eve.moe/jackyyf/navigator/mapping/elf"
+	"git.eve.moe/jackyyf/navigator/mapping/firefly"
 )

 var (
 	defaultServer = flag.String("fallback-node",
-		"xe-mci1-us.edge.eve.network",
-		"Default CDN node in case of any script error")
+		"xe-mci1-us", "Default CDN node in case of any script error")
 	defaultSuffix = flag.String("fallback-suffix",
 		".edge.eve.network",
 		"Default CDN suffix in case of any script error")
@ -16,14 +16,19 @@ var (

 func Initialize() {
 	elf.Initialize()
+	firefly.Initialize()
 }

 func Get(ip string) string {
-	ret := elf.GetMapping(ip)
-	if ret == "" {
-		return *defaultServer
+	node := elf.GetMapping(ip)
+	if node == "" {
+		node = *defaultServer
 	}
-	return ret
+	suffix := elf.GetSuffix(ip)
+	if suffix == "" {
+		suffix = *defaultSuffix
+	}
+	return node + suffix
 }

 func GetSuffix(ip string) string {
--- a/rules/map.starlark
+++ b/rules/map.starlark
@ -1,6 +1,11 @@
 WHOLESALE_INTERNET_10GE = "xe-mci1-us"
 HETZNER_FSN_1GE         = "ge-fsn1-de"
 HETZNER_HEL_1GE         = "ge-hel1-fi"
+CLOUDCONE_LAX1_1GE		= "ge-lax1-us"
+CLOUDCONE_LAX2_1GE		= "ge-lax2-us"
+CLOUDCONE_LAX3_1GE		= "ge-lax3-us"
+HOSTSOLUTIONS_OMR1_1GE  = "ge-omr1-ro"
+CLOUDCONE_LAX_LB		= (CLOUDCONE_LAX1_1GE, CLOUDCONE_LAX2_1GE, CLOUDCONE_LAX3_1GE)
 default_server          = WHOLESALE_INTERNET_10GE

 CHINA_MAINLAND_SUFFIX = ".eveedge.link"
@ -11,15 +16,23 @@ default_suffix        = GLOBAL_SUFFIX
 def getMapping(ip):
 	info = geoLookup(ip)
 	if not info:
-		return default_server + default_suffix
+		return default_server
 	if info.IspDomain == "ChinaMobile":
-		return HETZNER_FSN_1GE + CHINA_MAINLAND_SUFFIX
+		return HETZNER_FSN_1GE
+	if info.IspDomain == "ChinaTelecom":
+		return CLOUDCONE_LAX_LB
 	if info.CountryCode == "CN":
-		return default_server + CHINA_MAINLAND_SUFFIX
-	return default_server + GLOBAL_SUFFIX
+		return default_server
+	if ip == "0.11.45.14":
+		return {
+			default_server: 3,
+			CLOUDCONE_LAX1_1GE: 2,
+			CLOUDCONE_LAX2_1GE: 1,
+		}
+	return default_server

 def getNodes():
-	return ["xe-mci1-us", "ge-fsn1-de", "ge-lax1-us"]
+	return [WHOLESALE_INTERNET_10GE, HETZNER_FSN_1GE, CLOUDCONE_LAX_LB, HOSTSOLUTIONS_OMR1_1GE]

 def getSuffix(ip):
 	info = geoLookup(ip)
--- a/schema.sql
+++ b/schema.sql
@ -0,0 +1,12 @@
+CREATE TABLE speedtest_entry (
+    id bigserial PRIMARY KEY,
+    ip inet,
+    timestamp timestamptz
+);
+
+CREATE TABLE speedtest_result (
+    id bigserial PRIMARY KEY,
+    entry_id bigint REFERENCES speedtest_entry (id),
+    node varchar(32),
+    speed float8
+);
--- a/utils/BUILD.bazel
+++ b/utils/BUILD.bazel
@ -0,0 +1,9 @@
+load("@io_bazel_rules_go//go:def.bzl", "go_library")
+
+go_library(
+    name = "go_default_library",
+    srcs = ["utils.go"],
+    importpath = "git.eve.moe/jackyyf/navigator/utils",
+    visibility = ["//visibility:public"],
+    deps = ["@com_github_ipipdotnet_ipdb_go//:go_default_library"],
+)
--- a/utils/utils.go
+++ b/utils/utils.go
@ -0,0 +1,67 @@
+package utils
+
+import (
+	"encoding/json"
+	"github.com/ipipdotnet/ipdb-go"
+	"net"
+	"net/http"
+	"strings"
+)
+
+const (
+	remoteAddrHeader = "X-NAV-REMOTE-IP"
+)
+
+type errorMessage struct {
+	Error string `json:"error"`
+}
+
+func ResponseWithError(resp http.ResponseWriter, statusCode int, message string) {
+	resp.Header().Set("Content-Type", "text/plain")
+	resp.WriteHeader(statusCode)
+	resp.Write([]byte("error: " + message))
+}
+
+func ResponseWithJsonError(resp http.ResponseWriter, statusCode int, message string) {
+	resp.Header().Set("Content-Type", "application/json")
+	resp.WriteHeader(statusCode)
+	encoder := json.NewEncoder(resp)
+	err := encoder.Encode(&errorMessage{
+		Error: message,
+	})
+	if err != nil {
+		// This should never happen
+		panic("json marshal failed, check code")
+	}
+}
+
+func GetRemoteIP(req *http.Request) string {
+	if addr := req.Header.Get(remoteAddrHeader); addr != "" {
+		if net.ParseIP(addr).To4() == nil {
+			return ""
+		}
+		return addr
+	}
+	host, _, err := net.SplitHostPort(req.RemoteAddr)
+	if err != nil {
+		return ""
+	}
+	if net.ParseIP(host).To4() == nil {
+		return ""
+	}
+	return host
+}
+
+func BuildLocation(info *ipdb.CityInfo) string {
+	ret := ""
+	if info.CountryName != "" {
+		ret += info.CountryName + " "
+	}
+	if info.RegionName != "" {
+		ret += info.RegionName + " "
+	}
+	if info.CityName != "" {
+		ret += info.CityName + " "
+	}
+	return strings.TrimSpace(ret)
+}
Author	SHA1	Message	Date
Yifu Yu	d804dd98f6	Added beacon.html, with some refactor.	2020-02-02 16:39:15 +08:00
Yifu Yu	d47c459406	Refactored API.	2020-02-01 15:06:13 +08:00
Yifu Yu	2dbb47f519	Code refactor, adding GoLand workspace with Bazel plugin.	2020-01-12 22:09:30 +08:00
Yifu Yu	6ac03c18cc	Navigator now supports unweighted and weighted load balancing.	2019-12-26 01:10:26 +08:00