mirror of
https://github.com/penpot/penpot.git
synced 2025-05-30 21:56:11 +02:00
131 lines
3.1 KiB
Clojure
131 lines
3.1 KiB
Clojure
;; This Source Code Form is subject to the terms of the Mozilla Public
|
|
;; License, v. 2.0. If a copy of the MPL was not distributed with this
|
|
;; file, You can obtain one at http://mozilla.org/MPL/2.0/.
|
|
;;
|
|
;; Copyright (c) 2019 Andrey Antukh <niwi@niwi.nz>
|
|
|
|
(ns app.main.streams
|
|
"User interaction events and streams."
|
|
(:require
|
|
[beicon.core :as rx]
|
|
[app.main.store :as st]
|
|
[app.main.refs :as refs]
|
|
[app.common.geom.point :as gpt]))
|
|
|
|
;; --- User Events
|
|
|
|
(defrecord KeyboardEvent [type key shift ctrl alt])
|
|
|
|
(defn keyboard-event?
|
|
[v]
|
|
(instance? KeyboardEvent v))
|
|
|
|
(defrecord MouseEvent [type ctrl shift alt])
|
|
|
|
(defn mouse-event?
|
|
[v]
|
|
(instance? MouseEvent v))
|
|
|
|
(defn mouse-down?
|
|
[v]
|
|
(and (mouse-event? v)
|
|
(= :down (:type v))))
|
|
|
|
(defn mouse-up?
|
|
[v]
|
|
(and (mouse-event? v)
|
|
(= :up (:type v))))
|
|
|
|
(defn mouse-click?
|
|
[v]
|
|
(and (mouse-event? v)
|
|
(= :click (:type v))))
|
|
|
|
(defrecord PointerEvent [source pt ctrl shift alt])
|
|
|
|
(defn pointer-event?
|
|
[v]
|
|
(instance? PointerEvent v))
|
|
|
|
(defrecord ScrollEvent [point])
|
|
|
|
(defn scroll-event?
|
|
[v]
|
|
(instance? ScrollEvent v))
|
|
|
|
(defn interaction-event?
|
|
[event]
|
|
(or (keyboard-event? event)
|
|
(mouse-event? event)))
|
|
|
|
;; --- Derived streams
|
|
|
|
(defonce mouse-position
|
|
(let [sub (rx/behavior-subject nil)
|
|
ob (->> st/stream
|
|
(rx/filter pointer-event?)
|
|
(rx/filter #(= :viewport (:source %)))
|
|
(rx/map :pt))]
|
|
(rx/subscribe-with ob sub)
|
|
sub))
|
|
|
|
(defonce mouse-position-ctrl
|
|
(let [sub (rx/behavior-subject nil)
|
|
ob (->> st/stream
|
|
(rx/filter pointer-event?)
|
|
(rx/map :ctrl)
|
|
(rx/dedupe))]
|
|
(rx/subscribe-with ob sub)
|
|
sub))
|
|
|
|
(defonce mouse-position-shift
|
|
(let [sub (rx/behavior-subject nil)
|
|
ob (->> st/stream
|
|
(rx/filter pointer-event?)
|
|
(rx/map :shift)
|
|
(rx/dedupe))]
|
|
(rx/subscribe-with ob sub)
|
|
sub))
|
|
|
|
(defonce mouse-position-alt
|
|
(let [sub (rx/behavior-subject nil)
|
|
ob (->> st/stream
|
|
(rx/filter pointer-event?)
|
|
(rx/map :alt)
|
|
(rx/dedupe))]
|
|
(rx/subscribe-with ob sub)
|
|
sub))
|
|
|
|
(defonce keyboard-alt
|
|
(let [sub (rx/behavior-subject nil)
|
|
ob (->> st/stream
|
|
(rx/filter keyboard-event?)
|
|
(rx/map :alt)
|
|
(rx/dedupe))]
|
|
(rx/subscribe-with ob sub)
|
|
sub))
|
|
|
|
(defn mouse-position-deltas
|
|
[current]
|
|
(->> (rx/concat (rx/of current)
|
|
(rx/sample 10 mouse-position))
|
|
(rx/buffer 2 1)
|
|
(rx/map (fn [[old new]]
|
|
(gpt/subtract new old)))))
|
|
|
|
|
|
(defonce mouse-position-delta
|
|
(let [sub (rx/behavior-subject nil)
|
|
ob (->> st/stream
|
|
(rx/filter pointer-event?)
|
|
(rx/filter #(= :delta (:source %)))
|
|
(rx/map :pt))]
|
|
(rx/subscribe-with ob sub)
|
|
sub))
|
|
|
|
(defonce viewport-scroll
|
|
(let [sub (rx/behavior-subject nil)
|
|
sob (->> (rx/filter scroll-event? st/stream)
|
|
(rx/map :point))]
|
|
(rx/subscribe-with sob sub)
|
|
sub))
|