From 1e8b4ff23d392e6d41d5759ba771e3506146b74d Mon Sep 17 00:00:00 2001
From: xacadil <92389481+xacadil@users.noreply.github.com>
Date: Mon, 29 Apr 2024 21:50:51 +0500
Subject: [PATCH] Added disputes stream. (#19)

---
 .DS_Store             | Bin 8196 -> 8196 bytes
 tap_stripe/streams.py |  31 +++++++++++++++++++++++++++++--
 tap_stripe/tap.py     |   2 ++
 3 files changed, 31 insertions(+), 2 deletions(-)

diff --git a/.DS_Store b/.DS_Store
index a87e8da8e9e0d369a70091734d3deaa0f00486da..1c7fa19e57d20f14d8e3223f76af4f9be3eb5429 100644
GIT binary patch
literal 8196
zcmeHMTWl0n7(U;&(3vUNQ*5zI!?Lj=7Z>P_n_%4DD2Rx#+Y1FLvpWNwFr6tovs)00
z)tHz_yv7HGs1LpvV@QlqNQ@>LNlbiELr~<!#20<w#VDF+qW_sQOQ0?KK%ykfNzVDt
z`7h_p|Ihc&>Az)+p|fbTFxJ2rQ>Y8dt7({_3AyOgS}f#L5(U{aR$wOcnU@>)#-?dU
zj3@$81fmE;5r`rXMc`(L0NvT5Dc8C8r8F9&2t*OMB_kld4@v5Rrb9X@Y4GWwAt(We
ziV`4bG^aWsut|nA9nwij15?^lRu2eG5tbN`<|I!Fb)xBzPD(1x8KgNwcrwBY1;OcL
zmkiVy(vn7F6oDuL(<30#M`0_ON0od2>iRuryE&4b$&J~T=QlT>N35c9*6gY(wW_-6
zk<5rYp7C|R=ymFa-C~t>T{~Bv>$!f*93SR&U9RKnmSYwI1IsW;WzT@+818tdTXYOB
zu+2z;sw(O*Z#a6it#x%O*|xTAB9%P4zO^}(Y;RjLF`+8;O{+HS96o4|I_@*l6@;Gy
zHg}3^$7k}(_DWsSuh<`Dzb=G+DXON;iD$BX+5Tb9i=MgDv~}Mqnccc?dc(ZNBPX}y
zUFYF~St92K@~&MRbx2a1*X?|fl+6y?&RCC{-k?Q#Vm9cThkY>_^4x;o6<7@EhqEDf
zn9mbiZ6EV3*YWzzf=5(UPtBd*n7nJ*%C>bIJ9-{?=-h2JyjIid>IX`eXXR{jm+s|F
z$FQ6OedCtlj|@@x9N*e+nFUp?MJns)qvp9<UUS<W4e|J3F=rhrTK*B<q$qN)cw&*N
z@b~u^^vv5_Ls%MtBpy$Y(r&@;Dws4%wiaKqlnnH&N3MjAlUkvw+{+%McPUM^mR3dO
zMxU+cOgm()Sxc;~110HM$gJC-sDpWTbd(<2lf3x-X+`0m?-d6>sC)kQG1H;5g$tdD
zczl=OcNm6g2oHEoZM-+WMd4p7L*9s9Ft?8rz{>n>iW0mm;)|Vn49j<~2zLk}x15qi
z*rixY2rEtLW(l9B^inywCNx}JPK}f#X||c|p+s@m5%v^&m7QQG+1u<r_8~jVzF_Cs
zH|$$>k$um8Vn4HA*sts|`wI*}1vuhZfJQ7qGg{D!cC1Gyy3mbH*orLr(2qgv#Q}`K
z!a;a=3==qpr||+_#7lS?Z{i(%fYUgGPw*)|!&!WZ3-}HfaS5048-9;f$L7T9V~N;3
z(uG(#H3sCmJjPbgY+A}wYK(=cF*ajrBsTSK?rs0SQ{%#1kqq;0udAQGNMy*`jp-{;
zlE^EA?P?GQxV`3;2DlCKWGdz;WfnAQ3ln_=Z1eEcR4b<-uM&x-oD<qf?al<BMbMYa
z#oCetpG~lr%jJnwg2yP^<Z@M_MdKBeOKM=-o=9mNid?MI?$vlDWtCjsr!CYtQ{|!~
z(UssLN0fg<>px)i6g$m6BCLKzSp9+h$S$!zF$>kGCuBBZG494PEJqtwV-3~?2<=7>
zda)ThkRg=zV*vY*Lmnpf!^I&K0;C?p<9Gs3;y9kgb9f%F-~>+MHN1{D@D|>kg2ydo
zBua{pXToDCQ*dn8IY6>9j;}R~RyQ1h3b{jrsQ-Je|NH+9pA&5mMIeg6%^Lw!c4xXf
z>G`hrr4_YylKMXCq6xi8Ndprago@w?<v7tR|1hL^GL)r5Iw>hhsQu?Z1O$KWM)!Yo
L{|E59Wrx23<i#aW

literal 8196
zcmeHMU2GIp6u#e3=nO;KTP)1d4P~_;paohAg#w1{AAdz_*zFGmS!Z`fI$=Ar?96V_
z+E`!I;7{~P32HQ&_+W$=NH8%x_+WU@sH9ObzL@yp54`eVOgwjHN+@lgNR))R$-Upb
z=iGCD&U|O4XUiBvXUS+`EXEj<sS4yOHFFf97j;&VLP-T7$eytxGnvQS?3i1aH9HbS
z9*8^;c_8vY<blWo_ksuLn=Ohw&v!r2Ms4JQ$OHGK2gLg!K~-Qf#K{2tR|hqI3P31Q
z0KZV5@&Ml^5n?jL$pC#*S~JKV5Sk)PF%X!OJ|U(PCPSPIFfeBb%o)O+5oRdxcPG1q
zKb;{NVAMt)h&(Xc10sB6wvoA%x#w=r-?MoqOS((hLf&${=H?$DEvQ(ysIpS2R4boK
zjW}Z|Pxnf0r(QfFMrp^%XQ%smcEB>nGQ6(Ku|3_g&7yB$8756RI%wI3GuG*pY{T_!
zQ-MNJWF^C6<KwNHw>BkOx3x|*CC1w~H#a4=w6;x5DDtw#O*;=|PUJ^z=X7utgs%fu
zb;s3So$FqCx7-!nOZt2IUf05V$;x7NiIz&G)qxCOTBhUo6+Fwa-2t=c5@vXfOV`|=
zbL=OJrqB=OoP252b~C&-r{{B}yzZGD`FzTH&UA<MQ)%;*C;CHP*co=6qSxiyWH>Lm
z<{^_ztg_inhVGC>D~tIY%DJlL@x<!&8(X*U>gYM}#8h<+uT|B$WrJnQwX%8hu<qte
z+pz58{bQEljSQ3jY|nbeGK-2*i>9=#kD61}yrx!*Y4tL1l!r=L>txCDo(<P(SfwcZ
z;!%Tke%vvHr7=}o!>b?E8nh!q+Ep~EHDuWruhG`3X_pQsb6xQzkEl&*`UE{lg}Z@d
zliH&7=k=_aSGW<FZBg5_!E)d~h4%)+cC}6$$~mK>bYxcvWRGdPwPRx2gSzYW6-=9U
z=2zt43JqGfEFTuy4#N=V<TcfM_G;R&JE9lOzA<7KzbXz&@?MhrPl_~RtscYjoMNc#
z^OfAP%N9|Wo@u~fS(Y1<>jM7F@QBiwYz}E9vp8#Jo$LTR#w-ex3HByC!_KmI*{AFR
z`+|MNzGgqNpV&3_3;UJ*!Tw~|*$s9R41k0R)S?~_V=dO91#Q@dcI-eG_F+GIaS;7D
zf}=Qw3`S7ENx1MZftT<yUcp=V03YHbe2mX<4(IVXzQi~97T@7}{EWYF9XD`OS}dv3
z5~)gBE;UN4gELFhp)nZVAp~gyb!LS;g+?I^jl!Iv5%1~Qqwf3PL*rVN2!^E()Gb@S
zN<>K8&fT}j6tHiaaJSRg=kAPW>vPwSlRJ1frNvg%$JLb$^95T!k={Hdi#X$z;p~SR
zWg<Oa7!KF2qhT*!6b$1{8)TVZ<dQ#B<1L#N3M0N?sy?<tTTF4JD1k<8-$7C7@(N$G
zOI@jQ7V6^h&MsQy3co9^o@bZXW#Z~p;_7egcVg&2ScGcC(16ugLkwMyN3jK4iKE+n
zhIXR|dx@ookU|;*7=n&0axih+XKE4Sc%HcW0$#*vyoT5D2HwUyID@lz5AWj>T)@RU
z__%*2A8~muK9*BOJMY-XNjJ^onP$=Gu060ISRp3z|DO4O|G(>fq6H!kL>{<zJ%Ebt
zRCgzxZ@xFJ$h8wxpQb8`m^T@qZ$gcqjuZOnIN_~-7*an$Q-w`3#K{0jLghdIAt3l`
PH~RiZ-+!Nf_iOVnM(HDr

diff --git a/tap_stripe/streams.py b/tap_stripe/streams.py
index 8e822c0..6df0329 100644
--- a/tap_stripe/streams.py
+++ b/tap_stripe/streams.py
@@ -935,9 +935,9 @@ class CreditNoteLineItemsStream(stripeStream):
         th.Property("unit_amount_decimal", th.StringType),
         th.Property("unit_amount_excluding_tax", th.StringType),
     ).to_dict()
-class DisputesStream(stripeStream):
+class DisputesIssuingStream(stripeStream):
 
-    name = "disputes"
+    name = "disputes_issuing"
     object = "issuing.dispute"
     replication_key = "updated"
     
@@ -1352,3 +1352,30 @@ def get_records(self, context: Optional[dict]) -> Iterable[Dict[str, Any]]:
                 # Record filtered out during post_process()
                 continue
             yield transformed_record
+
+class DisputesStream(stripeStream):
+    name = "disputes"
+    object = "dispute"
+    replication_key = "updated"
+
+    @property
+    def path(self):
+        return "events" if self.get_from_events else "disputes"
+
+    schema = th.PropertiesList(
+        th.Property("id", th.StringType),
+        th.Property("object", th.StringType),
+        th.Property("amount", th.NumberType),
+        th.Property("charge", th.StringType),
+        th.Property("created", th.DateTimeType),
+        th.Property("updated", th.DateTimeType),
+        th.Property("currency", th.StringType),
+        th.Property("evidence", th.CustomType({"type": ["object", "string"]})),
+        th.Property("evidence_details", th.CustomType({"type": ["object", "string"]})),
+        th.Property("is_charge_refundable", th.BooleanType),
+        th.Property("livemode", th.BooleanType),
+        th.Property("metadata", th.CustomType({"type": ["object", "string"]})),
+        th.Property("payment_intent", th.StringType),
+        th.Property("reason", th.StringType),
+        th.Property("status", th.StringType),
+    ).to_dict()
diff --git a/tap_stripe/tap.py b/tap_stripe/tap.py
index 093b09a..288ba16 100644
--- a/tap_stripe/tap.py
+++ b/tap_stripe/tap.py
@@ -31,6 +31,7 @@
     TaxRatesStream,
     RefundsStream,
     PayoutReportsStream,
+    DisputesIssuingStream,
 )
 
 STREAM_TYPES = [
@@ -59,6 +60,7 @@
     TaxRatesStream,
     RefundsStream,
     PayoutReportsStream,
+    DisputesIssuingStream,
 ]