Add events and qrcodes to activities (#284)

assets/js/app.js

@@ -24,8 +24,11 @@ import {Socket} from "phoenix"
 import {LiveSocket} from "phoenix_live_view"
 import "../vendor/alpine.js";
 import topbar from "../vendor/topbar"
+import { QrScanner } from "./qr_reading.js";
 
-let Hooks = {};
+let Hooks = {
+  QrScanner: QrScanner
+};
 
 let csrfToken = document.querySelector("meta[name='csrf-token']").getAttribute("content")
 let liveSocket = new LiveSocket("/live", Socket, {

assets/js/qr_reading.js

@@ -0,0 +1,54 @@
+import { Html5Qrcode, Html5QrcodeSupportedFormats } from "../vendor/html5-qrcode.js"
+
+function parseURL(url) {
+  try {
+    const url_obj = new URL(url);
+
+    if (url_obj.host !== window.location.host) return null;
+    return url_obj.pathname.split("/").splice(1).join("/");
+  } catch {
+    return null;
+  }
+}
+
+export const QrScanner = {
+
+  mounted() {
+    const config = { fps: 4, qrbox: (width, height) => {return { width: width * 0.8, height: height * 0.9 }}};
+    this.scanner = new Html5Qrcode(this.el.id, { formatsToSupport: [ Html5QrcodeSupportedFormats.QR_CODE ] });
+
+    const onScanSuccess = (decodedText, decodedResult) => {
+      const pathname = parseURL(decodedText);
+      if (pathname != null && pathname !== this.lastRead) {
+        this.lastRead = pathname;
+        if (this.el.dataset.on_success)
+          Function("hook", "pathname", this.el.dataset.on_success)(this, pathname);
+      }
+    }
+
+    const startScanner = () => {
+      this.scanner.start({ facingMode: "environment" }, config, onScanSuccess)
+      .then((_) => {
+        if (this.el.dataset.on_start)
+          Function("hook", this.el.dataset.on_start)(this);
+      }, (e) => {
+        if (this.el.dataset.on_error)
+          Function("hook", this.el.dataset.on_error)(this);
+      });
+    }
+
+    if (this.el.dataset.ask_perm) {
+      document.getElementById(this.el.dataset.ask_perm).addEventListener("click", startScanner);
+    }
+
+    if (this.el.dataset.open_on_mount !== undefined)
+      startScanner();
+  },
+
+  destroyed() {
+    this.scanner.stop().then((_) => {
+      if (this.el.dataset.on_stop)
+        Function("hook", this.el.dataset.on_stop)(this);
+    });
+  }
+}

lib/atomic/accounts.ex

@@ -6,7 +6,7 @@ defmodule Atomic.Accounts do
   import Ecto.Query, warn: false
   alias Atomic.Repo
 
-  alias Atomic.Accounts.{Course, User, UserToken, UserNotifier}
+  alias Atomic.Accounts.{Course, User, UserNotifier, UserToken}
 
   ## Database getters
 
@@ -80,11 +80,41 @@ defmodule Atomic.Accounts do
     |> Repo.insert()
   end
 
-  def list_users() do
+  def list_users do
     User
     |> Repo.all()
   end
 
+  def get_course(id) do
+    Repo.get(Course, id)
+  end
+
+  @doc """
+  Return the initials of a name.
+
+  ## Examples
+
+      iex> extract_initials("John Doe")
+      "JD"
+
+      iex> extract_initials("John")
+      "J"
+
+      iex> extract_initials(nil)
+      ""
+
+  """
+  def extract_initials(nil), do: ""
+
+  def extract_initials(name) do
+    initials = name |> String.upcase() |> String.split(" ") |> Enum.map(&String.slice(&1, 0, 1))
+
+    case length(initials) do
+      1 -> hd(initials)
+      _ -> List.first(initials) <> List.last(initials)
+    end
+  end
+
   @doc """
   Returns an `%Ecto.Changeset{}` for tracking user changes.
 
@@ -373,7 +403,7 @@ defmodule Atomic.Accounts do
     |> User.changeset(attrs)
   end
 
-  def list_courses() do
+  def list_courses do
     Repo.all(Course)
   end
 

lib/atomic/accounts/user_notifier.ex

@@ -1,4 +1,5 @@
 defmodule Atomic.Accounts.UserNotifier do
+  @moduledoc false
   import Swoosh.Email
 
   alias Atomic.Mailer

lib/atomic/accounts/user_token.ex

@@ -1,4 +1,7 @@
 defmodule Atomic.Accounts.UserToken do
+  @moduledoc """
+  The UserToken context.
+  """
   use Atomic.Schema
 
   alias Atomic.Accounts.UserToken

lib/atomic/activities.ex

@@ -41,6 +41,18 @@ defmodule Atomic.Activities do
     |> Repo.preload(preloads)
   end
 
+  alias Atomic.Activities.Enrollment
+
+  def is_participating?(activity_id, user_id) do
+    Enrollment
+    |> where(activity_id: ^activity_id, user_id: ^user_id)
+    |> Repo.one()
+    |> case do
+      nil -> false
+      _ -> true
+    end
+  end
+
   @doc """
   Creates a activity.
 
@@ -233,6 +245,24 @@ defmodule Atomic.Activities do
   """
   def get_enrollment!(id), do: Repo.get!(Enrollment, id)
 
+  def get_enrollment!(activity_id, user_id) do
+    Enrollment
+    |> where(activity_id: ^activity_id, user_id: ^user_id)
+    |> Repo.one()
+  end
+
+  def get_user_enrolled(user, activity) do
+    enrollment =
+      Enrollment
+      |> where(user_id: ^user.id, activity_id: ^activity.id)
+      |> Repo.one()
+
+    case enrollment do
+      nil -> create_enrollment(activity, user)
+      _ -> enrollment
+    end
+  end
+
   @doc """
   Creates an enrollment.
 

lib/atomic/activities/activity.ex

@@ -12,10 +12,11 @@ defmodule Atomic.Activities.Activity do
   alias Atomic.Activities.Speaker
   alias Atomic.Departments
   alias Atomic.Departments.Department
+  alias Atomic.Events.Event
   @required_fields ~w(title description
                     minimum_entries maximum_entries)a
 
-  @optional_fields []
+  @optional_fields ~w(event_id)a
 
   schema "activities" do
     field :title, :string
@@ -35,6 +36,7 @@ defmodule Atomic.Activities.Activity do
       preload_order: [asc: :start]
 
     has_many :enrollments, Enrollment, foreign_key: :activity_id
+    belongs_to :event, Event
 
     timestamps()
   end

lib/atomic/events/enrollment.ex

@@ -0,0 +1,24 @@
+defmodule Atomic.Events.Enrollment do
+  @moduledoc """
+  An event enrollment.
+  """
+  use Atomic.Schema
+
+  alias Atomic.Accounts.User
+  alias Atomic.Events.Event
+
+  schema "enrollments" do
+    field :present, :boolean
+    belongs_to :event, Event
+    belongs_to :user, User
+
+    timestamps()
+  end
+
+  @doc false
+  def changeset(enrollment, attrs) do
+    enrollment
+    |> cast(attrs, [:event_id, :user_id, :present])
+    |> validate_required([:event_id, :user_id])
+  end
+end

lib/atomic/events/event.ex

@@ -0,0 +1,29 @@
+defmodule Atomic.Events.Event do
+  @moduledoc false
+  use Ecto.Schema
+  import Ecto.Changeset
+
+  alias Atomic.Activities.Activity
+  alias Atomic.Activities.Location
+  alias Atomic.Events.Enrollment
+  alias Atomic.Events.EventOrganization
+  @required_fields ~w(name location_id)a
+
+  schema "events" do
+    field :name, :string
+    field :description, :string
+    belongs_to :event_organization, EventOrganization
+    embeds_one :location, Location, on_replace: :delete
+    has_many :activities, Activity
+    has_many :enrollments, Enrollment
+
+    timestamps()
+  end
+
+  @doc false
+  def changeset(events, attrs) do
+    events
+    |> cast(attrs, @required_fields)
+    |> validate_required([])
+  end
+end

lib/atomic/events/event_organization.ex

@@ -0,0 +1,22 @@
+defmodule Atomic.Events.EventOrganization do
+  @moduledoc false
+  use Ecto.Schema
+  import Ecto.Changeset
+
+  alias Atomic.Events.Event
+  alias Atomic.Organizations.Organization
+
+  schema "event_organizations" do
+    belongs_to :event, Event
+    belongs_to :organization, Organization
+
+    timestamps()
+  end
+
+  @doc false
+  def changeset(event_organization, attrs) do
+    event_organization
+    |> cast(attrs, [:event_id, :organization_id])
+    |> validate_required([])
+  end
+end

lib/atomic/mailer.ex

@@ -1,3 +1,4 @@
 defmodule Atomic.Mailer do
+  @moduledoc false
   use Swoosh.Mailer, otp_app: :atomic
 end

lib/atomic/organizations.ex

@@ -7,12 +7,11 @@ defmodule Atomic.Organizations do
 
   use Atomic.Context
 
-  alias Atomic.Organizations.UserOrganization
-  alias Atomic.Repo
   alias Atomic.Accounts.User
   alias Atomic.Organizations.Membership
   alias Atomic.Organizations.Organization
   alias Atomic.Organizations.UserOrganization
+  alias Atomic.Repo
 
   @doc """
   Returns the list of organizations.

lib/atomic/organizations/card.ex

@@ -28,8 +28,6 @@ defmodule Atomic.Organizations.Card do
     field :number_y, :float
   end
 
-  # TODO: Validations
-
   def changeset(card, attrs) do
     card
     |> cast(attrs, @optional_fields)

lib/atomic/organizations/membership.ex

@@ -1,4 +1,5 @@
 defmodule Atomic.Organizations.Membership do
+  @moduledoc false
   use Atomic.Schema
 
   alias Atomic.Accounts.User

lib/atomic/organizations/organization.ex

@@ -1,11 +1,12 @@
 defmodule Atomic.Organizations.Organization do
+  @moduledoc false
   use Atomic.Schema
   alias Atomic.Accounts.User
-  alias Atomic.Departments.Department
   alias Atomic.Activities.Location
+  alias Atomic.Departments.Department
+  alias Atomic.Organizations.Card
   alias Atomic.Organizations.Membership
   alias Atomic.Partnerships.Partner
-  alias Atomic.Organizations.Card
   alias Atomic.Uploaders
 
   @required_fields ~w(name description)a

lib/atomic/organizations/users_organizations.ex

@@ -1,9 +1,10 @@
 defmodule Atomic.Organizations.UserOrganization do
+  @moduledoc false
   use Atomic.Schema
 
   alias Atomic.Accounts.User
-  alias Atomic.Organizations.Organization
   alias Atomic.Ecto.Year
+  alias Atomic.Organizations.Organization
 
   @required_fields ~w(year title user_id organization_id)a
 

lib/atomic/partnerships/partner.ex

@@ -4,8 +4,8 @@ defmodule Atomic.Partnerships.Partner do
   """
   use Atomic.Schema
   import Ecto.Changeset
-  alias Atomic.Uploaders
   alias Atomic.Organizations.Organization
+  alias Atomic.Uploaders
 
   @required_fields ~w(name description)a
 

lib/atomic/quantum/certificate_delivery.ex

@@ -13,9 +13,8 @@ defmodule Atomic.Quantum.CertificateDelivery do
 
   """
   import Ecto.Query, warn: false
-  alias Atomic.Repo
   alias Atomic.Mailer
-
+  alias Atomic.Repo
   alias Atomic.Activities.{Enrollment, Session}
 
   alias AtomicWeb.ActivityEmails
@@ -91,7 +90,7 @@ defmodule Atomic.Quantum.CertificateDelivery do
 
   # The result of the query is the IDs of the activities, not the structs
   # themselves.
-  defp last_sessions_query() do
+  defp last_sessions_query do
     now = DateTime.utc_now()
     minimum_finish = DateTime.add(now, -24, :hour)
 
@@ -115,7 +114,7 @@ defmodule Atomic.Quantum.CertificateDelivery do
   # - The user has participated in the session (meaning the present field
   # of the enrollment will be true)
 
-  defp included_enrollments() do
+  defp included_enrollments do
     enrollments =
       from s in subquery(last_sessions_query()),
         inner_join: e in Enrollment,

lib/atomic/scheduler.ex

@@ -1,3 +1,4 @@
 defmodule Atomic.Scheduler do
+  @moduledoc false
   use Quantum, otp_app: :atomic
 end

lib/atomic/uploaders/card.ex

@@ -1,4 +1,5 @@
 defmodule Atomic.Uploaders.Card do
+  @moduledoc false
   use Waffle.Definition
   use Waffle.Ecto.Definition
   alias Atomic.Organizations.Organization