package com.juick.service; import com.juick.User; import com.juick.model.AnonymousUser; import org.springframework.beans.factory.annotation.Value; import org.springframework.stereotype.Repository; import org.springframework.transaction.annotation.Transactional; import org.springframework.web.util.UriComponents; import org.springframework.web.util.UriComponentsBuilder; import javax.annotation.Nonnull; import javax.inject.Inject; import java.util.List; @Repository public class ActivityPubService extends BaseJdbcService implements SocialService { @Value("${ap_base_uri:http://localhost:8080/}") private String baseUri; @Inject private UserService userService; @Transactional(readOnly = true) @Override public @Nonnull User getUserByAccountUri(String acct) { UriComponents baseUriComponents = UriComponentsBuilder.fromUriString(baseUri).build(); UriComponents acctComponents = UriComponentsBuilder.fromUriString(acct).build(); if (acctComponents.getHost().equals(baseUriComponents.getHost())) { // /u/ugnich -> ugnich String userName = acctComponents.getPath().substring(3); return userService.getUserByName(userName); } return AnonymousUser.INSTANCE; } @Transactional(readOnly = true) @Override public @Nonnull List getFollowers(User user) { return getJdbcTemplate().queryForList("SELECT acct FROM followers WHERE user_id=?", String.class, user.getUid()); } @Transactional @Override public void addFollower(User user, String acct) { getJdbcTemplate().update("INSERT INTO followers(user_id, acct) " + "VALUES(?, ?)", user.getUid(), acct); } @Transactional @Override public void removeFollower(User user, String acct) { getJdbcTemplate().update("DELETE FROM followers WHERE user_id=? AND acct=?", user.getUid(), acct); } @Transactional @Override public void removeAccount(String acct) { getJdbcTemplate().update("DELETE FROM followers WHERE acct=?", acct); } }