Develop

authentication/migrations/0042_twitterconnection_twitter_id.py

@@ -0,0 +1,18 @@
+# Generated by Django 4.0.4 on 2024-08-30 15:47
+
+from django.db import migrations, models
+
+
+class Migration(migrations.Migration):
+
+    dependencies = [
+        ('authentication', '0041_alter_brightidconnection_user_profile_and_more'),
+    ]
+
+    operations = [
+        migrations.AddField(
+            model_name='twitterconnection',
+            name='twitter_id',
+            field=models.CharField(max_length=255, null=True, unique=True),
+        ),
+    ]

authentication/models.py

@@ -260,10 +260,11 @@ class TwitterConnection(BaseThirdPartyConnection):
     access_token_secret = models.CharField(
         max_length=255, unique=True, blank=True, null=True
     )
+    twitter_id = models.CharField(max_length=255, unique=True, null=True)
     driver = TwitterDriver()
 
     def is_connected(self):
-        return bool(self.access_token and self.access_token_secret)
+        return bool(self.twitter_id)
 
     @property
     def tweet_count(self):
@@ -279,11 +280,8 @@ def follower_count(self):
     def username(self):
         return self.driver.get_username(self.access_token, self.access_token_secret)
 
-    @property
-    def twitter_id(self):
-        return self.driver.get_twitter_id(
-            self, self.access_token, self.access_token_secret
-        )
+    def get_twitter_id(self):
+        return self.driver.get_twitter_id(self.access_token, self.access_token_secret)
 
     def is_replied(self, self_tweet_id, target_tweet_id):
         return self.driver.get_is_replied(

authentication/serializers.py

@@ -46,7 +46,7 @@ class Meta:
         fields = ["pk", "wallet_type", "address", "signature", "message"]
 
     def is_valid(self, raise_exception=False):
-        super_is_validated = super().is_valid(raise_exception)
+        super_is_validated = super().is_valid(raise_exception=raise_exception)
 
         address = self.validated_data.get("address")
         message = self.validated_data.get("message")
@@ -208,8 +208,8 @@ class Meta:
         ]
 
     def is_valid(self, raise_exception=False):
-        super_is_validated = super().is_valid(raise_exception)
-        is_address_valid = self.validate_address(raise_exception)
+        super_is_validated = super().is_valid(raise_exception=raise_exception)
+        is_address_valid = self.validate_address(raise_exception=raise_exception)
 
         return is_address_valid and super_is_validated
 
@@ -237,7 +237,7 @@ class Meta:
         ]
 
     def is_valid(self, raise_exception=False):
-        super_is_validated = super().is_valid(raise_exception)
+        super_is_validated = super().is_valid(raise_exception=raise_exception)
         is_address_valid = self.validate_address(raise_exception)
 
         return is_address_valid and super_is_validated
@@ -255,7 +255,7 @@ class Meta:
         ]
 
     def is_valid(self, raise_exception=False):
-        super_is_validated = super().is_valid(raise_exception)
+        super_is_validated = super().is_valid(raise_exception=raise_exception)
         is_address_valid = self.validate_address(raise_exception)
 
         return is_address_valid and super_is_validated
@@ -273,7 +273,7 @@ class Meta:
         ]
 
     def is_valid(self, raise_exception=False):
-        super_is_validated = super().is_valid(raise_exception)
+        super_is_validated = super().is_valid(raise_exception=raise_exception)
         is_address_valid = self.validate_address(raise_exception)
 
         return is_address_valid and super_is_validated

authentication/views.py

@@ -738,7 +738,15 @@ def get(self, request, *args, **kwargs):
 
         twitter_connection.access_token = access_token
         twitter_connection.access_token_secret = access_token_secret
+        twitter_connection.twitter_id = twitter_connection.get_twitter_id()
 
-        twitter_connection.save(update_fields=("access_token", "access_token_secret"))
-
+        try:
+            twitter_connection.save(
+                update_fields=("access_token", "access_token_secret", "twitter_id")
+            )
+        except IntegrityError:
+            raise ValidationError(
+                """We can not connect you twitter account,
+                may be your account is connected before"""
+            )
         return Response({}, HTTP_200_OK)

brightIDfaucet/settings.py

@@ -72,7 +72,12 @@ def str2bool(v):
 MEMCACHED_PASSWORD = os.environ.get("MEMCACHEDCLOUD_PASSWORD")
 DEPLOYMENT_ENV = os.environ.get("DEPLOYMENT_ENV")
 
+CLOUDFLARE_IMAGES_ACCOUNT_ID = os.environ.get("CLOUDFLARE_ACCOUNT_ID")
+CLOUDFLARE_IMAGES_API_TOKEN = os.environ.get("CLOUDFLARE_API_TOKEN")
+CLOUDFLARE_IMAGES_ACCOUNT_HASH = os.environ.get("CLOUDFLARE_ACCOUNT_HASH")
+
 CLOUDFLARE_TURNSTILE_SECRET_KEY = os.environ.get("CLOUDFLARE_TURNSTILE_SECRET_KEY")
+H_CAPTCHA_SECRET = os.environ.get("H_CAPTCHA_SECRET")
 
 assert DEPLOYMENT_ENV in ["dev", "main"]
 
@@ -163,6 +168,16 @@ def before_send(event, hint):
 
 WSGI_APPLICATION = "brightIDfaucet.wsgi.application"
 
+STORAGES = {
+    "default": { 
+        "BACKEND": "cloudflare_images.storage.CloudflareImagesStorage",
+    },
+    "staticfiles": {  # default
+        "BACKEND": "django.contrib.staticfiles.storage.StaticFilesStorage",
+    },
+}
+
+
 # Database
 DATABASES = {"default": dj_database_url.config(conn_max_age=600)}
 

core/constraints/__init__.py

@@ -16,6 +16,7 @@
     BrightIDAuraVerification,
     BrightIDMeetVerification,
 )
+from core.constraints.captcha import HasVerifiedCloudflareCaptcha, HasVerifiedHCaptcha
 from core.constraints.EAS import Attest, BeAttestedBy
 from core.constraints.ens import HasENSVerification
 from core.constraints.farcaster import (
@@ -63,7 +64,7 @@
     IsFollowingTwitterBatch,
     IsFollowinTwitterUser,
 )
-from core.constraints.captcha import HasVerifiedCloudflareCaptcha
+from core.constraints.zora import DidMintZoraNFT
 
 
 def get_constraint(constraint_label: str) -> ConstraintVerification:

core/constraints/abstract.py

@@ -16,6 +16,7 @@ class ConstraintApp(Enum):
     MUON = "muon"
     OPTIMISM = "optimism"
     OCTANT = "octant"
+    ZORA = "zora"
 
     @classmethod
     def choices(cls):
@@ -59,9 +60,10 @@ class ConstraintVerification(ABC):
     invalid_cache_until = 60
     valid_cache_until = 60 * 60
 
-    def __init__(self, user_profile) -> None:
+    def __init__(self, user_profile, *, obj=None) -> None:
         self.user_profile = user_profile
         self._param_values = {}
+        self.obj = obj
 
     def get_info(self, *args, **kwargs):
         pass

core/constraints/arbitrum.py

@@ -68,7 +68,7 @@ def has_bridged(self, from_time=None):
             }
 
         res = subgraph.send_post_request(
-            subgraph.path.get("arb_bridge_mainnet"), query=query, vars=vars
+            subgraph.paths.get("arb_bridge_mainnet"), query=query, vars=vars
         )
         match res:
             case None:

core/constraints/captcha.py

@@ -4,6 +4,7 @@
 
 import logging
 
+from core.thirdpartyapp.hcaptcha import HCaptchaUtil
 from core.utils import RequestContextExtractor
 
 
@@ -35,3 +36,32 @@ def is_observed(self, *args, **kwargs) -> bool:
         return request_context.ip is not None and turnstile_token is not None and cloudflare.is_verified(
             turnstile_token, request_context.ip
         )
+
+
+
+
+class HasVerifiedHCaptcha(ConstraintVerification):
+    _param_keys = []
+    app_name = ConstraintApp.GENERAL.value
+    is_cachable = True
+    valid_cache_until = 2 * 60
+    invalid_cache_until = 0
+
+    def is_observed(self, *args, **kwargs) -> bool:
+
+        context = kwargs.get("context")
+
+        if context is None or context.get("request") is None:
+            return False
+
+        hcaptcha = HCaptchaUtil()
+
+        request_context: RequestContextExtractor = RequestContextExtractor(
+            context["request"]
+        )
+
+        turnstile_token = request_context.data.get("cf-turnstile-response")
+
+        return request_context.ip is not None and turnstile_token is not None and hcaptcha.is_verified(
+            turnstile_token, request_context.ip
+        )

core/constraints/zora.py

@@ -0,0 +1,33 @@
+from datetime import datetime
+
+from core.constraints.abstract import (
+    ConstraintApp,
+    ConstraintParam,
+    ConstraintVerification,
+)
+from core.thirdpartyapp import ZoraUtil
+
+
+class DidMintZoraNFT(ConstraintVerification):
+    app_name = ConstraintApp.ZORA.value
+    _param_keys = [ConstraintParam.ADDRESS]
+
+    def __init__(self, user_profile) -> None:
+        super().__init__(user_profile)
+
+    def is_observed(self, *args, **kwargs) -> bool:
+        zora_util = ZoraUtil()
+        user_addresses = self.user_addresses
+        nft_address = self.param_values[ConstraintParam.ADDRESS.name]
+        for address in user_addresses:
+            res = zora_util.get_tx(nft_address=nft_address, address=address)
+            if res is None:
+                continue
+            for tx in res.values:
+                if (
+                    tx.get("method") == "mint"
+                    and datetime.strptime(tx.get("timestamp"), "%Y-%m-%dT%H:%M:%S.%fZ")
+                    > self.obj.start_at
+                ):
+                    return True
+        return False

core/fields.py

@@ -0,0 +1,30 @@
+"""
+Contains all the fields related classes to support custom features
+such as variants in Cloudflare Images
+"""
+
+from django.db import models
+
+
+class BigNumField(models.Field):
+    empty_strings_allowed = False
+
+    def __init__(self, *args, **kwargs):
+        kwargs["max_length"] = 200  # or some other number
+        super().__init__(*args, **kwargs)
+
+    def db_type(self, connection):
+        return "numeric"
+
+    def get_internal_type(self):
+        return "BigNumField"
+
+    def to_python(self, value):
+        if isinstance(value, str):
+            return int(value)
+
+        return value
+
+    def get_prep_value(self, value):
+        return str(value)
+

core/models.py

@@ -6,12 +6,13 @@
 from django.contrib.postgres.fields import ArrayField
 from django.db import models
 from django.utils.translation import gettext_lazy as _
-from core.constraints.captcha import HasVerifiedCloudflareCaptcha
 from encrypted_model_fields.fields import EncryptedCharField
 from rest_framework.exceptions import ValidationError
 from solders.keypair import Keypair
 from solders.pubkey import Pubkey
 
+from core.constraints.captcha import HasVerifiedCloudflareCaptcha, HasVerifiedHCaptcha
+
 from .constraints import (
     AllowListVerification,
     Attest,
@@ -28,6 +29,7 @@
     DidDelegateArbToAddress,
     DidDelegateOPToAddress,
     DidLikedFarcasterCast,
+    DidMintZoraNFT,
     DidMirrorOnLensPublication,
     DidQuoteTweet,
     DidRecastFarcasterCast,
@@ -157,6 +159,8 @@ class Type(models.TextChoices):
         IsFollowingTwitterBatch,
         IsFollowingFarcasterBatch,
         HasVerifiedCloudflareCaptcha,
+        DidMintZoraNFT,
+        HasVerifiedHCaptcha
     ]
 
     name = models.CharField(

core/tests.py

@@ -396,6 +396,7 @@ def setUp(self):
             oauth_token_secret=oauth_token_secret,
             access_token="test",
             access_token_secret="test",
+            twitter_id="1",
         )
 
         self.not_connected_user_profile = UserProfile.objects.create(

core/thirdpartyapp/__init__.py

@@ -5,3 +5,4 @@
 from .lens import LensUtil  # noqa: F401
 from .subgraph import Subgraph
 from .twitter import RapidTwitter, TwitterUtils
+from .zora import ZoraUtil

core/thirdpartyapp/config.py

@@ -22,3 +22,4 @@
     ),
 }
 SUBGRAPH_BASE_URL = os.getenv("SUBGRAPH_BASE_URL", "https://api.studio.thegraph.com")
+ZORA_BASE_URL = os.getenv("ZORA_BASE_URL", "https://explorer.zora.energy")

core/thirdpartyapp/hcaptcha.py

@@ -0,0 +1,24 @@
+import logging
+from django.conf import settings
+import requests
+
+
+logger = logging.getLogger(__name__)
+
+
+class HCaptchaUtil:
+    secret_key = settings.H_CAPTCHA_SECRET
+    api_url = "https://api.hcaptcha.com"
+
+    def is_verified(self, token: str, ip: str) -> bool:
+        try:
+            res = requests.post(
+                f"{self.api_url}/siteverify",
+                data={"secret": self.secret_key, "response": token, "remoteip": ip},
+            )
+
+            return res.ok and res.json()["success"]
+        except Exception as e:
+            logger.info(f"Error occurred during hcaptcha verification {str(e)}")
+
+            return False

core/thirdpartyapp/subgraph.py

@@ -7,7 +7,7 @@
 
 class Subgraph:
     requests = RequestHelper(config.SUBGRAPH_BASE_URL)
-    path = {
+    paths = {
         "unitap_pass": "query/73675/unitap-pass-eth/version/latest",
         "arb_bridge_mainnet": "query/21879/unitap-arb-bridge-mainnet/version/latest",
     }
@@ -53,7 +53,7 @@ def get_unitap_pass_holders(
         while True:
             vars["skip"] = count
             res = self.send_post_request(
-                self.path.get("unitap_pass"), query=query, vars=vars
+                self.paths.get("unitap_pass"), query=query, vars=vars
             )
             match res:
                 case None: