Decline owner invites

app/components/pending-owner-invite-row.js

@@ -0,0 +1,45 @@
+import Ember from 'ember';
+
+export default Ember.Component.extend({
+    isAccepted: false,
+    isDeclined: false,
+    isError: false,
+    inviteError: 'default error message',
+
+    actions: {
+        acceptInvitation(invite) {
+            invite.set('accepted', true);
+            invite.save()
+                .then(() => {
+                    this.set('isAccepted', true);
+                })
+                .catch((error) => {
+                    this.set('isError', true);
+                    if (error.payload) {
+                        this.set('inviteError',
+                            `Error in accepting invite: ${error.payload.errors[0].detail}`
+                        );
+                    } else {
+                        this.set('inviteError', 'Error in accepting invite');
+                    }
+                });
+        },
+        declineInvitation(invite) {
+            invite.set('accepted', false);
+            invite.save()
+                .then(() => {
+                    this.set('isDeclined', true);
+                })
+                .catch((error) => {
+                    this.set('isError', true);
+                    if (error.payload) {
+                        this.set('inviteError',
+                            `Error in declining invite: ${error.payload.errors[0].detail}`
+                        );
+                    } else {
+                        this.set('inviteError', 'Error in declining invite');
+                    }
+                });
+        }
+    }
+});

app/models/crate-owner-invite.js

@@ -4,5 +4,6 @@ export default DS.Model.extend({
     invited_by_username: DS.attr('string'),
     crate_name: DS.attr('string'),
     crate_id: DS.attr('number'),
-    created_at: DS.attr('date')
+    created_at: DS.attr('date'),
+    accepted: DS.attr('boolean', { defaultValue: false })
 });

app/serializers/crate-owner-invite.js

@@ -4,5 +4,8 @@ export default DS.RESTSerializer.extend({
     primaryKey: 'crate_id',
     modelNameFromPayloadKey() {
         return 'crate-owner-invite';
+    },
+    payloadKeyFromModelName() {
+        return 'crate_owner_invite';
     }
 });

app/styles/me.scss

@@ -195,6 +195,14 @@
         @include justify-content(space-between);
 
         .date { @include flex-grow(2); text-align: right; }
+        .label {
+            .small-text {
+                font-size: 90%;
+            }
+        }
+        .name {
+            width: 200px;
+        }
     }
 }
 

app/templates/components/pending-owner-invite-row.hbs

@@ -0,0 +1,40 @@
+<div class='row'>
+    {{#if isAccepted }}
+        <p>Success! You've been added as an owner of crate
+            {{#link-to 'crate' invite.crate_name}}{{invite.crate_name}}{{/link-to}}.
+        </p>
+    {{else if isDeclined}}
+        <p>Declined. You have not been added as an owner of crate
+            {{#link-to 'crate' invite.crate_name}}{{invite.crate_name}}{{/link-to}}.
+        </p>
+    {{else}}
+    <div class='info'>
+        <div class='name'>
+            <h3>
+                {{#link-to 'crate' invite.crate_name}}
+                    {{invite.crate_name}}
+                {{/link-to}}
+            </h3>
+        </div>
+        <div class='invite'>
+            <p>Invited by:
+                {{#link-to 'user' invite.invited_by_username}}
+                    {{invite.invited_by_username}}
+                {{/link-to}}
+            </p>
+        </div>
+        <div class='sent'>
+            <span class='small'>{{moment-from-now invite.created_at}}</span>
+        </div>
+        <div class='actions'>
+            <button class='small yellow-button' {{action 'acceptInvitation' invite}}>Accept</button>
+            <button class='small yellow-button' {{action 'declineInvitation' invite}}>Decline</button>
+        </div>
+        {{#if isError}}
+            <div class='label'>
+                <p class='small-text'>{{inviteError}}</p>
+            </div>
+        {{/if}}
+    </div>
+    {{/if}}
+</div>

app/templates/me/pending-invites.hbs

@@ -8,31 +8,9 @@
 <div id='my-invites'>
     <div class='white-rows'>
         {{#each model as |invite|}}
-            <div class='row'>
-                <div class='info'>
-                    <div class='name'>
-                        <h3>
-                            {{#link-to 'crate' invite.crate_name}}
-                                {{invite.crate_name}}
-                            {{/link-to}}
-                        </h3>
-                    </div>
-                    <div class='invite'>
-                        <p>Invited by: 
-                            {{#link-to 'user' invite.invited_by_username}}
-                                {{invite.invited_by_username}}
-                            {{/link-to}}
-                        </p>
-                    </div>
-                    <div class='sent'>
-                        <span class='small'>{{moment-from-now invite.created_at}}</span>
-                    </div>
-                    <div class='actions'>
-                        <button class='small yellow-button'>Accept</button>
-                        <button class='small yellow-button'>Deny</button>
-                    </div>
-                </div>
-            </div>
+            {{pending-owner-invite-row invite=invite}}
+        {{else}}
+            <p>You don't seem to have any pending invitations.</p>
         {{/each}}
     </div>
 </div>

src/crate_owner_invitation.rs

@@ -1,12 +1,14 @@
 use conduit::{Request, Response};
 use diesel::prelude::*;
 use time::Timespec;
+use serde_json;
 
 use db::RequestTransaction;
-use schema::{crate_owner_invitations, users, crates};
+use schema::{crate_owner_invitations, users, crates, crate_owners};
 use user::RequestUser;
-use util::errors::CargoResult;
+use util::errors::{CargoResult, human};
 use util::RequestUtils;
+use owner::{CrateOwner, OwnerKind};
 
 /// The model representing a row in the `crate_owner_invitations` database table.
 #[derive(Clone, Copy, Debug, PartialEq, Eq, Identifiable, Queryable)]
@@ -80,3 +82,93 @@ pub fn list(req: &mut Request) -> CargoResult<Response> {
     }
     Ok(req.json(&R { crate_owner_invitations }))
 }
+
+#[derive(Deserialize)]
+struct OwnerInvitation {
+    crate_owner_invite: InvitationResponse,
+}
+
+#[derive(Deserialize, Serialize, Debug, Copy, Clone)]
+pub struct InvitationResponse {
+    pub crate_id: i32,
+    pub accepted: bool,
+}
+
+/// Handles the `PUT /me/crate_owner_invitations/:crate_id` route.
+pub fn handle_invite(req: &mut Request) -> CargoResult<Response> {
+
+    let conn = &*req.db_conn()?;
+
+
+    let mut body = String::new();
+    req.body().read_to_string(&mut body)?;
+
+    let crate_invite: OwnerInvitation = serde_json::from_str(&body).map_err(|_| {
+        human("invalid json request")
+    })?;
+
+    let crate_invite = crate_invite.crate_owner_invite;
+
+    if crate_invite.accepted {
+        accept_invite(req, conn, crate_invite)
+    } else {
+        decline_invite(req, conn, crate_invite)
+    }
+}
+
+fn accept_invite(
+    req: &mut Request,
+    conn: &PgConnection,
+    crate_invite: InvitationResponse,
+) -> CargoResult<Response> {
+    let user_id = req.user()?.id;
+    use diesel::{insert, delete};
+    let pending_crate_owner = crate_owner_invitations::table
+        .filter(crate_owner_invitations::crate_id.eq(crate_invite.crate_id))
+        .filter(crate_owner_invitations::invited_user_id.eq(user_id))
+        .first::<CrateOwnerInvitation>(&*conn)?;
+
+    let owner = CrateOwner {
+        crate_id: crate_invite.crate_id,
+        owner_id: user_id,
+        created_by: pending_crate_owner.invited_by_user_id,
+        owner_kind: OwnerKind::User as i32,
+    };
+
+    conn.transaction(|| {
+        insert(&owner).into(crate_owners::table).execute(conn)?;
+        delete(
+            crate_owner_invitations::table
+                .filter(crate_owner_invitations::crate_id.eq(crate_invite.crate_id))
+                .filter(crate_owner_invitations::invited_user_id.eq(user_id)),
+        ).execute(conn)?;
+
+        #[derive(Serialize)]
+        struct R {
+            crate_owner_invitation: InvitationResponse,
+        }
+        Ok(req.json(&R { crate_owner_invitation: crate_invite }))
+    })
+}
+
+fn decline_invite(
+    req: &mut Request,
+    conn: &PgConnection,
+    crate_invite: InvitationResponse,
+) -> CargoResult<Response> {
+    use diesel::delete;
+    let user_id = req.user()?.id;
+
+    delete(
+        crate_owner_invitations::table
+            .filter(crate_owner_invitations::crate_id.eq(crate_invite.crate_id))
+            .filter(crate_owner_invitations::invited_user_id.eq(user_id)),
+    ).execute(conn)?;
+
+    #[derive(Serialize)]
+    struct R {
+        crate_owner_invitation: InvitationResponse,
+    }
+
+    Ok(req.json(&R { crate_owner_invitation: crate_invite }))
+}

src/lib.rs

@@ -191,6 +191,10 @@ pub fn middleware(app: Arc<App>) -> MiddlewareBuilder {
         "/me/crate_owner_invitations",
         C(crate_owner_invitation::list),
     );
+    api_router.put(
+        "/me/crate_owner_invitations/:crate_id",
+        C(crate_owner_invitation::handle_invite),
+    );
     api_router.get("/summary", C(krate::summary));
     api_router.put("/confirm/:email_token", C(user::confirm_user_email));
     api_router.put("/users/:user_id/resend", C(user::regenerate_token_and_send));

src/tests/all.rs

@@ -15,6 +15,7 @@ extern crate dotenv;
 extern crate git2;
 extern crate semver;
 extern crate serde;
+#[macro_use]
 extern crate serde_json;
 extern crate time;
 extern crate url;