Compare commits

..

No commits in common. "71fa674ce3069c5fdce812980800b30398913710" and "99fffe1bd244ff108bed6826fb6cf8727a062aff" have entirely different histories.

2 changed files with 89 additions and 41 deletions

View File

@ -16,8 +16,7 @@
(:export :start-server :seed)
;; Note that we use a nickname for the ActivityStreams vocab!
;; I recommend doing likewise; save yourself some typing!
(:local-nicknames (:ass :activity-servist/vocab/activity)
(:lp :activity-servist/vocab/litepub)))
(:local-nicknames (:as :activity-servist/vocab/activity)))
(in-package #:activitypub-example)
@ -27,12 +26,11 @@
(defvar *store* (make-hash-table :test #'equal)
"Our “object-store” — stores all ActivityPub objects, mapped by their IRI @ID.")
(defvar *config*
'(:host "http://localhost:8080" :address "127.0.0.1" :port 8080 :fetch fetch))
(defvar *config* '(:address "localhost" :protocol "http" :port 8080 :fetch fetch))
(defvar *user-id-format* "~A/users/~A"
(defvar *user-id-format* "~A://~A/users/~A"
"The format we use for users @IDs/URIs.
The first parameter is the protocol+host, and the second is the username.
The first parameter is the protocol, the second the host, and the third the username.
For example: https://localhost:8080/users/lena.")
@ -93,16 +91,15 @@ That is, an “acct:username@host.tld” URI."
(destructuring-bind (user host)
(str:split "@" sans-preceding-@)
(format nil *user-id-format*
(host-w-scheme host) user))))
(host-scheme host) host user))))
(defun host-w-scheme (hostname)
"Helper-function for ACCT-URI->ID. From a hostname, returns scheme://hostname.
If it matches our configured :HOST (in *CONFIG*), simply returns :HOSTs value.
(defun host-scheme (hostname)
"Helper-function for ACCT-URI->ID. Returns the expected protocol of a hostname.
If its our configured :ADDRESS (in *CONFIG*), then return *CONFIG*s :PROTOCOL.
Otherwise, assume https."
(let ((our-host (getf *config* :host)))
(if (equal (quri:uri-host (quri:uri our-host)) hostname)
our-host
(format nil "https://~A" hostname))))
(if (equal (getf *config* :address) hostname)
(getf *config* :protocol)
"https"))
@ -116,7 +113,7 @@ Otherwise, assume “https”."
;;; Users
;;; ————————————————————————————————————————
(defclass user (ass:person lp:object)
(defclass user (as:person)
((inbox
:accessor user-inbox
:initform nil
@ -139,13 +136,15 @@ Otherwise, assume “https”."
The ID and ENDPOINTS are derived using the parameter USERNAME and the global *USER-ID-FORMAT*."
(let ((obj (make-instance 'user))
(uri (format nil *user-id-format*
(getf *config* :host) username)))
(getf *config* :protocol)
(getf *config* :address)
username)))
(flet ((sub-uri (path)
(format nil "~A/~A" uri path)))
(setf (ass:name obj) username)
(setf (as:name obj) username)
(setf (json-ld:@id obj) uri)
(setf (ass:inbox obj) (sub-uri "inbox"))
(setf (ass:outbox obj) (sub-uri "outbox"))
(setf (ass:following obj) (sub-uri "following"))
(setf (ass:followers obj) (sub-uri "followers")))
(setf (as:inbox obj) (sub-uri "inbox"))
(setf (as:outbox obj) (sub-uri "outbox"))
(setf (as:following obj) (sub-uri "following"))
(setf (as:followers obj) (sub-uri "followers")))
obj))

View File

@ -29,12 +29,12 @@
;;; Globals
;;; ————————————————————————————————————————
(defvar *config* '(:host "http://localhost:8080" :address "127.0.0.1" :port 8080)
(defvar *config* '(:address "localhost" :port 8080 :protocol "https")
"Configuration for the server, a property-list.
There are three optional properties:
:HOST, the public-facing URI of the server.
:ADDRESS, the address the server is exposed on.
:PORT, the port the server is exposed on.
:PROTOCOL, either https or http (the latter for testing, only!).
:ADDRESS, the servers domain-name/address.
:PORT, the servers port.
There is one required property:
:FETCH, a function used as a callback by activity-servist.
@ -43,11 +43,20 @@ There is one required property:
This function should simply return an object from your storage, queried by a URI.
The URI parameter is going to be either an @ID or an account-URI of the form acct:username@hostname.")
(defun users ()
"List of the server's usernames."
'("servistchjo"))
(defun userhosts ()
"List of the server's usernames + hostname."
(mapcar (lambda (username) (str:concat username "@" "etc.xwx.moe"))
(users)))
(defun directories ()
"Alist of the server's paths and their response functions."
'((".well-known/webfinger" . http-webfinger)
(".well-known/host-meta" . http-host-meta)
("" . http-object))) ; By default, assume object.
'(("u/" . http-user-dir)
(".well-known/webfinger" . http-webfinger)
(".well-known/host-meta" . http-host-meta)))
(defvar *privkey*
(alexandria:read-file-into-string
@ -77,12 +86,16 @@ Returns the ActivityPub object associated with the given URI."
(,(str:concat "<?xml version=\"1.0\" encoding=\"UTF-8\"?>
<XRD xmlns=\"http://docs.oasis-open.org/ns/xri/xrd-1.0\">
<link rel=\"lrdd\" type=\"application/xrd+xml\" template=\""
(getf *config* :host)
(getf *config* :protocol)
"://"
(getf *config* :address)
"/.well-known/webfinger?resource={uri}\"/>
</XRD>
"))))
;;; Webfinger response
;;; ————————————————————————————————————————
@ -119,19 +132,55 @@ For information on the property-lists format, see the dosctring of WEBTENTACL
;;; Object requests
;;; User info response(s)
;;; ————————————————————————————————————————
(defun http-object (env path-items params)
"If an ActivityPub object is requested, serve it (if such an object
can be found). Uses the callback :FETCH, defined in *CONFIG*."
(let* ((uri (reduce (lambda (a b) (format nil "~A/~A" a b))
(append (list (getf *config* :host)) path-items)))
(obj (fetch uri)))
(if obj
(list 200 '(:content-type "application/json")
(list (yason:with-output-to-string* () (yason:encode-object obj))))
`(400 (:content-type "text/plain")
("Such an object doesnt exist!")))))
(defun http-user-dir (env path-items params)
"Respond to requests within the /u/* directory."
(let ((user (car path-items)))
;; In case of request for the user's actor.
(if (member user (users) :test 'equal)
`(200 (:content-type "application/activity+json")
(,(user-actor env user))))))
(defun user-actor (config username)
"The JSON of a user's actor."
(let* ((user-root
(str:concat (getf *config* :protocol) "://" (getf *config* :address) "/u/" username))
(yason:*symbol-encoder*
'yason:encode-symbol-as-lowercase))
(yason:with-output-to-string* ()
(yason:encode-alist
`(("@context" . ("https://www.w3.org/ns/activitystreams"
"https://w3id.org/security/v1"
"https://litepub.social/litepub/context.jsonld"))
("endpoints" . ,(alexandria:plist-hash-table (list "sharedInbox" "https://etc.xwx.moe/inbox")))
("url" . ,user-root)
("id" . ,user-root)
("type" . "Person")
("preferredUsername" . ,username)
("name" . "Servistiĉo")
("inbox" . ,(str:concat user-root "/inbox"))
("outbox" . ,(str:concat user-root "/outbox"))
("discoverable" . t)
("summary" . "Mi estas simpla roboto, kiu montras ke iomete ekfunkcias activity-servist.
ĉu mi rajtas demeti la servistinan kostumon, nun?
Mi ne estas knabino!!")
("icon"
. ,(alexandria:plist-hash-table
(list
"type" "Image"
"url" "https://xwx.moe/etc/servisticho-profilbildo.jpg")))
("image"
. ,(alexandria:plist-hash-table
(list
"type" "Image"
"url" "https://xwx.moe/etc/servisticho-standardo.png")))
("publicKey"
. ,(alexandria:plist-hash-table
(list
"id" (str:concat user-root "#main-key")
"owner" user-root
"publicKeyPem" *pubkey*))))))))