リファクタリング Phase 3: ツーリング整備（ameba / CI / spec）

.github/workflows/ci.yml

@@ -0,0 +1,31 @@
+name: ci
+
+on:
+  push:
+    branches: [master]
+  pull_request:
+
+jobs:
+  check:
+    name: format / lint / spec
+    runs-on: ubuntu-24.04-arm
+    steps:
+      - name: checkout
+        uses: actions/checkout@v4
+
+      - name: install crystal
+        uses: crystal-lang/install-crystal@v1
+        with:
+          crystal: latest
+
+      - name: install shards
+        run: shards install
+
+      - name: check format
+        run: crystal tool format --check
+
+      - name: lint with ameba
+        run: ./bin/ameba
+
+      - name: run specs
+        run: crystal spec

.gitignore

@@ -6,7 +6,8 @@ jspm_packages
 .serverless
 
 bootstrap
+bin
 lib
 env.yml
-
-.idea/
+
+.idea/

shard.lock

@@ -1,6 +1,6 @@
-version: 1.0
+version: 2.0
 shards:
-  clim:
-    github: at-grandpa/clim
-    version: 0.4.1
+  ameba:
+    git: https://github.com/crystal-ameba/ameba.git
+    version: 1.6.4
 

shard.yml

@@ -10,4 +10,9 @@ targets:
 
 crystal: ">= 1.20.0"
 
+development_dependencies:
+  ameba:
+    github: crystal-ameba/ameba
+    version: ~> 1.6
+
 license: MIT

spec/github/models_spec.cr

@@ -0,0 +1,113 @@
+require "../spec_helper"
+
+private def subject_from(type : String, url = "", latest_comment_url = "")
+  Github::Subject.from_json({
+    type:               type,
+    title:              "title",
+    url:                url,
+    latest_comment_url: latest_comment_url,
+  }.to_json)
+end
+
+describe Github::Subject do
+  describe "#update?" do
+    it "is true for tracked subject types" do
+      [
+        Github::Subject::Type::PULL_REQUEST,
+        Github::Subject::Type::ISSUE,
+        Github::Subject::Type::COMMIT,
+        Github::Subject::Type::DISCUSSION,
+      ].each do |type|
+        subject_from(type).update?.should be_true
+      end
+    end
+
+    it "is false for unknown subject types" do
+      subject_from("Release").update?.should be_false
+    end
+  end
+
+  describe "#color" do
+    it "returns a distinct color per known type" do
+      subject_from(Github::Subject::Type::PULL_REQUEST).color.should eq "#F6CEE3"
+      subject_from(Github::Subject::Type::ISSUE).color.should eq "#A9D0F5"
+      subject_from(Github::Subject::Type::COMMIT).color.should eq "#f5d7a9"
+      subject_from(Github::Subject::Type::DISCUSSION).color.should eq "#7fffd4"
+    end
+
+    it "falls back to a default color for unknown types" do
+      subject_from("Release").color.should eq "#D8D8D8"
+    end
+  end
+
+  describe "#comment_url" do
+    it "prefers latest_comment_url when present" do
+      subject = subject_from("Issue", url: "u", latest_comment_url: "c")
+      subject.comment_url.should eq "c"
+    end
+
+    it "falls back to url when latest_comment_url is blank" do
+      subject = subject_from("Issue", url: "u", latest_comment_url: "")
+      subject.comment_url.should eq "u"
+    end
+  end
+end
+
+describe Github::Notification do
+  describe "#mention?" do
+    it "is true for reasons that mention the user" do
+      Github::Notification::MENTION_REASONS.each do |reason|
+        notification_from(reason).mention?.should be_true
+      end
+    end
+
+    it "is false for non-mention reasons" do
+      notification_from("subscribed").mention?.should be_false
+      notification_from("ci_activity").mention?.should be_false
+    end
+  end
+
+  it "parses a GitHub notifications API payload" do
+    notifications = Array(Github::Notification).from_json(NOTIFICATIONS_FIXTURE)
+    notifications.size.should eq 1
+
+    notification = notifications.first
+    notification.reason.should eq "mention"
+    notification.subject.type.should eq "Issue"
+    notification.subject.title.should eq "Spurious failure"
+    notification.repository.full_name.should eq "octocat/Hello-World"
+    notification.mention?.should be_true
+  end
+end
+
+private def notification_from(reason : String)
+  Github::Notification.from_json({
+    reason:     reason,
+    subject:    {type: "Issue", title: "title"},
+    repository: {owner: {login: "octocat"}},
+  }.to_json)
+end
+
+NOTIFICATIONS_FIXTURE = <<-JSON
+[
+  {
+    "reason": "mention",
+    "subject": {
+      "title": "Spurious failure",
+      "url": "https://api.github.com/repos/octocat/Hello-World/issues/1",
+      "latest_comment_url": "https://api.github.com/repos/octocat/Hello-World/issues/comments/1",
+      "type": "Issue"
+    },
+    "repository": {
+      "full_name": "octocat/Hello-World",
+      "html_url": "https://github.com/octocat/Hello-World",
+      "owner": {
+        "login": "octocat",
+        "avatar_url": "https://github.com/images/error/octocat.gif",
+        "html_url": "https://github.com/octocat"
+      }
+    },
+    "subscription_url": "https://api.github.com/notifications/threads/1/subscription"
+  }
+]
+JSON

spec/slack/models_spec.cr

@@ -0,0 +1,22 @@
+require "../spec_helper"
+
+describe Slack::Attachment do
+  it "omits unset fields when serialized" do
+    json = Slack::Attachment.new(text: "hello", color: "#000000").to_json
+    parsed = JSON.parse(json)
+
+    parsed["text"].should eq "hello"
+    parsed["color"].should eq "#000000"
+    parsed.as_h.has_key?("title").should be_false
+  end
+end
+
+describe Slack::Post do
+  it "wraps attachments under an attachments key" do
+    post = Slack::Post.new([Slack::Attachment.new(text: "a")])
+    parsed = JSON.parse(post.to_json)
+
+    parsed["attachments"].as_a.size.should eq 1
+    parsed["attachments"][0]["text"].should eq "a"
+  end
+end

spec/spec_helper.cr

@@ -1,2 +1,3 @@
 require "spec"
-require "../src/github_notifications_slack"
+require "../src/github/models"
+require "../src/slack/models"

src/main.cr

@@ -29,8 +29,8 @@ error_uc = Error::Usecase.new(
 Serverless::Lambda.handler "github_notifications_slack" do |_|
   begin
     notify_uc.check_notifications
-  rescue err
-    error_uc.alert err
-    raise err
+  rescue error
+    error_uc.alert error
+    raise error
   end
 end

src/runtime/lambda.cr

@@ -22,10 +22,10 @@ module Serverless
           body = yield event
           header = nil
           url = "http://#{ENV["AWS_LAMBDA_RUNTIME_API"]}/2018-06-01/runtime/invocation/#{request_id}/response"
-        rescue err
+        rescue error
           body = {
             msg: "Internal Lambda Error",
-            err: err.message,
+            err: error.message || error.class.name,
           }
           header = HTTP::Headers{"Lambda-Runtime-Function-Error-Type" => "Unhandled"}
           url = "http://#{ENV["AWS_LAMBDA_RUNTIME_API"]}/2018-06-01/runtime/invocation/#{request_id}/error"